Package com.google.cloud.bigquery.storage.v1beta2

Class BigQueryWriteGrpc.BigQueryWriteFutureStub

  • Enclosing class:
    BigQueryWriteGrpc
    public static final class BigQueryWriteGrpc.BigQueryWriteFutureStub
extends io.grpc.stub.AbstractFutureStub<BigQueryWriteGrpc.BigQueryWriteFutureStub>
    A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryWrite. 
     BigQuery Write API.
 The Write API can be used to write data to BigQuery.
 The [google.cloud.bigquery.storage.v1
   API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1)
   should be used instead of the v1beta2 API for BigQueryWrite operations.

    • Method Detail

      • createWriteStream

        public com.google.common.util.concurrent.ListenableFuture<WriteStream> createWriteStream​(CreateWriteStreamRequest request)
         Creates a write stream to the given table.
 Additionally, every table has a special COMMITTED stream named '_default'
 to which data can be written. This stream doesn't need to be created using
 CreateWriteStream. It is a stream that can be used simultaneously by any
 number of clients. Data written to this stream is considered committed as
 soon as an acknowledgement is received.

      • getWriteStream

        public com.google.common.util.concurrent.ListenableFuture<WriteStream> getWriteStream​(GetWriteStreamRequest request)
         Gets a write stream.

      • finalizeWriteStream

        public com.google.common.util.concurrent.ListenableFuture<FinalizeWriteStreamResponse> finalizeWriteStream​(FinalizeWriteStreamRequest request)
         Finalize a write stream so that no new data can be appended to the
 stream. Finalize is not supported on the '_default' stream.

      • batchCommitWriteStreams

        public com.google.common.util.concurrent.ListenableFuture<BatchCommitWriteStreamsResponse> batchCommitWriteStreams​(BatchCommitWriteStreamsRequest request)
         Atomically commits a group of `PENDING` streams that belong to the same
 `parent` table.
 Streams must be finalized before commit and cannot be committed multiple
 times. Once a stream is committed, data in the stream becomes available
 for read operations.

      • flushRows

        public com.google.common.util.concurrent.ListenableFuture<FlushRowsResponse> flushRows​(FlushRowsRequest request)
         Flushes rows to a BUFFERED stream.
 If users are appending rows to BUFFERED stream, flush operation is
 required in order for the rows to become available for reading. A
 Flush operation flushes up to any previously flushed offset in a BUFFERED
 stream, to the offset specified in the request.
 Flush is not supported on the _default stream, since it is not BUFFERED.