Class TableDataWriteChannel (2.46.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
Name Description
length int
last boolean
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
Type Description
Job

stateBuilder()

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