Package com.google.cloud.bigquery

Class TableDataWriteChannel

java.lang.Object

com.google.cloud.BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>

com.google.cloud.bigquery.TableDataWriteChannel

All Implemented Interfaces:

Restorable<WriteChannel>, WriteChannel, Closeable, AutoCloseable, Channel, WritableByteChannel

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.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.BaseWriteChannel

BaseWriteChannel.BaseState<ServiceOptionsT extends ServiceOptions<?,ServiceOptionsT>,EntityT extends Serializable>

Method Summary

Modifier and Type	Method	Description
protected void	flushBuffer(int length, boolean last)
Job	getJob()	Returns the Job created to insert the rows.
protected com.google.cloud.bigquery.TableDataWriteChannel.StateImpl.Builder	stateBuilder()

Methods inherited from class com.google.cloud.BaseWriteChannel

capture, close, getBuffer, getChunkSize, getDefaultChunkSize, getEntity, getLimit, getMinChunkSize, getOptions, getPosition, getUploadId, isOpen, restore, setChunkSize, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

flushBuffer

protected void flushBuffer(int length,
 boolean last)

Specified by:

flushBuffer in class BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>

stateBuilder

protected com.google.cloud.bigquery.TableDataWriteChannel.StateImpl.Builder stateBuilder()

Specified by:

stateBuilder in class BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>

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.