You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClient.java
+32-12Lines changed: 32 additions & 12 deletions
Original file line number
Diff line number
Diff line change
@@ -145,7 +145,11 @@ public BigQueryWriteStub getStub() {
145
145
146
146
// AUTO-GENERATED DOCUMENTATION AND METHOD.
147
147
/**
148
-
* Creates a write stream to the given table.
148
+
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
149
+
* stream named '_default' to which data can be written. This stream doesn't need to be created
150
+
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
151
+
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
152
+
* received.
149
153
*
150
154
* <p>Sample code:
151
155
*
@@ -174,7 +178,11 @@ public final Stream.WriteStream createWriteStream(
174
178
175
179
// AUTO-GENERATED DOCUMENTATION AND METHOD.
176
180
/**
177
-
* Creates a write stream to the given table.
181
+
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
182
+
* stream named '_default' to which data can be written. This stream doesn't need to be created
183
+
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
184
+
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
185
+
* received.
178
186
*
179
187
* <p>Sample code:
180
188
*
@@ -202,7 +210,11 @@ public final Stream.WriteStream createWriteStream(String parent, Stream.WriteStr
202
210
203
211
// AUTO-GENERATED DOCUMENTATION AND METHOD.
204
212
/**
205
-
* Creates a write stream to the given table.
213
+
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
214
+
* stream named '_default' to which data can be written. This stream doesn't need to be created
215
+
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
216
+
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
217
+
* received.
206
218
*
207
219
* <p>Sample code:
208
220
*
@@ -225,7 +237,11 @@ public final Stream.WriteStream createWriteStream(Storage.CreateWriteStreamReque
225
237
226
238
// AUTO-GENERATED DOCUMENTATION AND METHOD.
227
239
/**
228
-
* Creates a write stream to the given table.
240
+
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
241
+
* stream named '_default' to which data can be written. This stream doesn't need to be created
242
+
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
243
+
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
244
+
* received.
229
245
*
230
246
* <p>Sample code:
231
247
*
@@ -390,7 +406,8 @@ public final Stream.WriteStream getWriteStream(Storage.GetWriteStreamRequest req
390
406
391
407
// AUTO-GENERATED DOCUMENTATION AND METHOD.
392
408
/**
393
-
* Finalize a write stream so that no new data can be appended to the stream.
409
+
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
410
+
* supported on the '_default' stream.
394
411
*
395
412
* <p>Sample code:
396
413
*
@@ -415,7 +432,8 @@ public final Storage.FinalizeWriteStreamResponse finalizeWriteStream(WriteStream
415
432
416
433
// AUTO-GENERATED DOCUMENTATION AND METHOD.
417
434
/**
418
-
* Finalize a write stream so that no new data can be appended to the stream.
435
+
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
436
+
* supported on the '_default' stream.
419
437
*
420
438
* <p>Sample code:
421
439
*
@@ -438,7 +456,8 @@ public final Storage.FinalizeWriteStreamResponse finalizeWriteStream(String name
438
456
439
457
// AUTO-GENERATED DOCUMENTATION AND METHOD.
440
458
/**
441
-
* Finalize a write stream so that no new data can be appended to the stream.
459
+
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
460
+
* supported on the '_default' stream.
442
461
*
443
462
* <p>Sample code:
444
463
*
@@ -464,7 +483,8 @@ public final Storage.FinalizeWriteStreamResponse finalizeWriteStream(
464
483
465
484
// AUTO-GENERATED DOCUMENTATION AND METHOD.
466
485
/**
467
-
* Finalize a write stream so that no new data can be appended to the stream.
486
+
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
487
+
* supported on the '_default' stream.
468
488
*
469
489
* <p>Sample code:
470
490
*
@@ -603,7 +623,7 @@ public final Storage.BatchCommitWriteStreamsResponse batchCommitWriteStreams(
603
623
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
604
624
* operation is required in order for the rows to become available for reading. A Flush operation
605
625
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
606
-
* the request.
626
+
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
607
627
*
608
628
* <p>Sample code:
609
629
*
@@ -631,7 +651,7 @@ public final Storage.FlushRowsResponse flushRows(WriteStreamName writeStream) {
631
651
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
632
652
* operation is required in order for the rows to become available for reading. A Flush operation
633
653
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
634
-
* the request.
654
+
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
635
655
*
636
656
* <p>Sample code:
637
657
*
@@ -657,7 +677,7 @@ public final Storage.FlushRowsResponse flushRows(String writeStream) {
657
677
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
658
678
* operation is required in order for the rows to become available for reading. A Flush operation
659
679
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
660
-
* the request.
680
+
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
661
681
*
662
682
* <p>Sample code:
663
683
*
@@ -685,7 +705,7 @@ public final Storage.FlushRowsResponse flushRows(Storage.FlushRowsRequest reques
685
705
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
686
706
* operation is required in order for the rows to become available for reading. A Flush operation
687
707
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
688
-
* the request.
708
+
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
Copy file name to clipboardExpand all lines: grpc-google-cloud-bigquerystorage-v1alpha2/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteGrpc.java
0 commit comments