Skip to content

Commit 8f9c6b3

Browse files
committed
format
1 parent bbbf40f commit 8f9c6b3

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

src/bigquery_proto_writer.cpp

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -298,8 +298,7 @@ void BigqueryProtoWriter::WriteChunk(DataChunk &chunk, const std::map<std::strin
298298
}
299299
auto estimated_size_increase = serialized_msg.size() + APPEND_ROWS_ROW_OVERHEAD;
300300

301-
if (rows_in_batch > 0 &&
302-
current_request_bytes + estimated_size_increase > DEFAULT_APPEND_ROWS_SOFT_LIMIT) {
301+
if (rows_in_batch > 0 && current_request_bytes + estimated_size_increase > DEFAULT_APPEND_ROWS_SOFT_LIMIT) {
303302
SendAppendRequest(request);
304303
request = create_request();
305304
rows = request.mutable_proto_rows()->mutable_rows();
@@ -326,8 +325,7 @@ void BigqueryProtoWriter::WriteChunk(DataChunk &chunk, const std::map<std::strin
326325
}
327326
}
328327

329-
void BigqueryProtoWriter::SendAppendRequest(
330-
const google::cloud::bigquery::storage::v1::AppendRowsRequest &request) {
328+
void BigqueryProtoWriter::SendAppendRequest(const google::cloud::bigquery::storage::v1::AppendRowsRequest &request) {
331329
if (!request.has_proto_rows() || request.proto_rows().rows().serialized_rows_size() == 0) {
332330
return;
333331
}

0 commit comments

Comments
 (0)