File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -275,25 +275,25 @@ try (BulkStreamWriter writer = greptimeDB.bulkStreamWriter(schema)) {
275275 for (int batch = 0 ; batch < batchCount; batch++ ) {
276276 // Get a TableBufferRoot for this batch
277277 Table . TableBufferRoot table = writer. tableBufferRoot(1000 ); // column buffer size
278-
278+
279279 // Add rows to the batch
280280 for (int row = 0 ; row < rowsPerBatch; row++ ) {
281281 Object [] rowData = generateRow(batch, row);
282282 table. addRow(rowData);
283283 }
284-
284+
285285 // Complete the table to prepare for transmission
286286 table. complete();
287-
287+
288288 // Send the batch and get a future for completion
289289 CompletableFuture<Integer > future = writer. writeNext();
290-
290+
291291 // Wait for the batch to be processed (optional)
292292 Integer affectedRows = future. get();
293-
293+
294294 System . out. println(" Batch " + batch + " wrote " + affectedRows + " rows" );
295295 }
296-
296+
297297 // Signal completion of the stream
298298 writer. completed();
299299}
You can’t perform that action at this time.
0 commit comments