Package com.google.cloud.bigquery
Class TableDataWriteChannel
- java.lang.Object
-
- com.google.cloud.BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>
-
- com.google.cloud.bigquery.TableDataWriteChannel
-
- All Implemented Interfaces:
com.google.cloud.Restorable<com.google.cloud.WriteChannel>
,com.google.cloud.WriteChannel
,Closeable
,AutoCloseable
,Channel
,WritableByteChannel
public class TableDataWriteChannel extends com.google.cloud.BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.google.cloud.BaseWriteChannel
com.google.cloud.BaseWriteChannel.BaseState<ServiceOptionsT extends com.google.cloud.ServiceOptions<?,ServiceOptionsT>,EntityT extends Serializable>
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
flushBuffer(int length, boolean last)
Job
getJob()
Returns theJob
created to insert the rows.protected com.google.cloud.bigquery.TableDataWriteChannel.StateImpl.Builder
stateBuilder()
-
-
-
Method Detail
-
flushBuffer
protected void flushBuffer(int length, boolean last)
- Specified by:
flushBuffer
in classcom.google.cloud.BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>
-
stateBuilder
protected com.google.cloud.bigquery.TableDataWriteChannel.StateImpl.Builder stateBuilder()
- Specified by:
stateBuilder
in classcom.google.cloud.BaseWriteChannel<BigQueryOptions,WriteChannelConfiguration>
-
getJob
public Job getJob()
Returns theJob
created to insert the rows. The job is available only once the upload finished and the channel was closed, returnsnull
otherwise.
-
-