Class TableDataWriteChannel (2.25.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

Inherited Members

com.google.cloud.BaseWriteChannel.capture()

com.google.cloud.BaseWriteChannel.close()

com.google.cloud.BaseWriteChannel.flushBuffer(int,boolean)

com.google.cloud.BaseWriteChannel.getBuffer()

com.google.cloud.BaseWriteChannel.getChunkSize()

com.google.cloud.BaseWriteChannel.getDefaultChunkSize()

com.google.cloud.BaseWriteChannel.getEntity()

com.google.cloud.BaseWriteChannel.getLimit()

com.google.cloud.BaseWriteChannel.getMinChunkSize()

com.google.cloud.BaseWriteChannel.getOptions()

com.google.cloud.BaseWriteChannel.getPosition()

com.google.cloud.BaseWriteChannel.getUploadId()

com.google.cloud.BaseWriteChannel.isOpen()

com.google.cloud.BaseWriteChannel.restore(com.google.cloud.BaseWriteChannel.BaseState)

com.google.cloud.BaseWriteChannel.setChunkSize(int)

com.google.cloud.BaseWriteChannel.stateBuilder()

com.google.cloud.BaseWriteChannel.write(java.nio.ByteBuffer)

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)

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()