Class ConnectionWorker (2.21.0)

public class ConnectionWorker implements AutoCloseable

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

TODO: Support batching.

Inheritance

java.lang.Object > ConnectionWorker

Implements

AutoCloseable

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Methods

getApiMaxRequestBytes()

public static long getApiMaxRequestBytes()

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

Returns

Type	Description
long

Constructors

ConnectionWorker(String streamName, ProtoSchema writerSchema, long maxInflightRequests, long maxInflightBytes, FlowController.LimitExceededBehavior limitExceededBehavior, String traceId, BigQueryWriteClient client, boolean ownsBigQueryWriteClient)

public ConnectionWorker(String streamName, ProtoSchema writerSchema, long maxInflightRequests, long maxInflightBytes, FlowController.LimitExceededBehavior limitExceededBehavior, String traceId, BigQueryWriteClient client, boolean ownsBigQueryWriteClient)

Parameters

Name	Description
streamName	`String`
writerSchema	`ProtoSchema`
maxInflightRequests	`long`
maxInflightBytes	`long`
limitExceededBehavior	`LimitExceededBehavior`
traceId	`String`
client	`BigQueryWriteClient`
ownsBigQueryWriteClient	`boolean`

Methods

append(ProtoRows rows)

public ApiFuture<AppendRowsResponse> append(ProtoRows rows)

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

Parameter

Name	Description
rows	`ProtoRows`

Returns

Type	Description
ApiFuture<AppendRowsResponse>

append(ProtoRows rows, long offset)

public ApiFuture<AppendRowsResponse> append(ProtoRows rows, long offset)

Schedules the writing of rows at given offset.

Parameters

Name	Description
rows	`ProtoRows`
offset	`long`

Returns

Type	Description
ApiFuture<AppendRowsResponse>

close()

public void close()

Close the stream writer. Shut down all resources.

getInflightWaitSeconds()

public long getInflightWaitSeconds()

Returns

Type	Description
long

getUpdatedSchema()

public synchronized TableSchema getUpdatedSchema()

Thread-safe getter of updated TableSchema

Returns

Type	Description
TableSchema

getWriterId()

public String getWriterId()

Returns

Type	Description
String	a unique Id for the writer.