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.
Methods
flushBuffer(int length, boolean last)
protected void flushBuffer(int length, boolean last)
Name | Description |
length | int |
last | boolean |
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.
Type | Description |
Job |
stateBuilder()
protected TableDataWriteChannel.StateImpl.Builder stateBuilder()
Type | Description |
com.google.cloud.bigquery.TableDataWriteChannel.StateImpl.Builder |
com.google.cloud.BaseWriteChannel.stateBuilder()