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 and Description
protected void	flushBuffer(int length, boolean last) Writes length bytes of BaseWriteChannel.getBuffer() to the BaseWriteChannel.getUploadId() URL.
Job	getJob() Returns the Job created to insert the rows.
protected com.google.cloud.bigquery.TableDataWriteChannel.StateImpl.Builder	stateBuilder() Creates a BaseWriteChannel.BaseState.Builder for the current write channel.

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 Detail

flushBuffer

protected void flushBuffer(int length,
                           boolean last)

Description copied from class: BaseWriteChannel

Writes length bytes of BaseWriteChannel.getBuffer() to the BaseWriteChannel.getUploadId() URL.

Specified by:

flushBuffer in class BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>

Parameters:

length - the number of bytes to write from BaseWriteChannel.getBuffer()

last - if true the resumable session is closed

stateBuilder

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

Description copied from class: BaseWriteChannel

Creates a BaseWriteChannel.BaseState.Builder for the current write channel.

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.