Class StreamWriter (3.8.0)

A BigQuery Stream Writer that can be used to write data into BigQuery Table.

TODO: Support batching.

The maximum size of one request. Defined by the API.

Constructs a new StreamWriter.Builder using the given stream.

Constructs a new StreamWriter.Builder using the given stream and client.

Sets the maximum time a request is allowed to be waiting in request waiting queue. Under very low chance, it's possible for append request to be waiting indefintely for request callback when Google networking SDK does not detect the networking breakage. The default timeout is 15 minutes. We are investigating the root cause for callback not triggered by networking SDK.

Schedules the writing of rows at the end of current stream.

Schedules the writing of rows at given offset.

Example of writing rows with specific offset.

 ApiFuture<AppendRowsResponse> future = writer.append(rows, 0);
 ApiFutures.addCallback(future, new ApiFutureCallback<AppendRowsResponse>() {
   public void onSuccess(AppendRowsResponse response) {
     if (!response.hasError()) {
       System.out.println("written with offset: " + response.getAppendResult().getOffset());
     } else {
       System.out.println("received an in stream error: " + response.getError().toString());
     }
   }

   public void onFailure(Throwable t) {
     System.out.println("failed to write: " + t);
   }
 }, MoreExecutors.directExecutor());
 

Close the stream writer. Shut down all resources.

Returns the wait of a request in Client side before sending to the Server. Request could wait in Client because it reached the client side inflight request limit (adjustable when constructing the StreamWriter). The value is the wait time for the last sent request. A constant high wait value indicates a need for more throughput, you can create a new Stream for to increase the throughput in exclusive stream case, or create a new Writer in the default stream case.

Thread-safe getter of updated TableSchema.

This will return the updated schema only when the creation timestamp of this writer is older than the updated schema.

Sets the missing value interpretation map for the stream writer. The input missingValueInterpretationMap is used for all write requests unless otherwise changed.