Class TableDataWriteChannel (2.28.0)

public class TableDataWriteChannel extends BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>

WriteChannel implementation to stream data into a BigQuery table. Use #getJob() to get the job used to insert streamed data. Please notice that #getJob() returns null until the channel is closed.

Inheritance

java.lang.Object > com.google.cloud.BaseWriteChannel > TableDataWriteChannel

Methods

flushBuffer(int length, boolean last)

protected void flushBuffer(int length, boolean last)
Parameters
NameDescription
lengthint
lastboolean
Overrides
com.google.cloud.BaseWriteChannel.flushBuffer(int,boolean)

getJob()

public Job getJob()

Returns the Job created to insert the rows. The job is available only once the upload finished and the channel was closed, returns null otherwise.

Returns
TypeDescription
Job

stateBuilder()

protected TableDataWriteChannel.StateImpl.Builder stateBuilder()
Returns
TypeDescription
com.google.cloud.bigquery.TableDataWriteChannel.StateImpl.Builder
Overrides
com.google.cloud.BaseWriteChannel.stateBuilder()