org.apache.beam.sdk.io.gcp.bigquery

Interface BigQueryServices.StreamAppendClient

All Superinterfaces:

java.lang.AutoCloseable

Enclosing interface:

BigQueryServices

public static interface BigQueryServices.StreamAppendClient
extends java.lang.AutoCloseable

An interface for appending records to a Storage API write stream.

Method Summary

Modifier and Type	Method and Description
com.google.api.core.ApiFuture<com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse>	appendRows(long offset, com.google.cloud.bigquery.storage.v1beta2.ProtoRows rows, Descriptors.Descriptor descriptor) Append rows to a Storage API write stream at the given offset.
void	pin() Pin this object.
void	unpin() Unpin this object.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

appendRows

com.google.api.core.ApiFuture<com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse> appendRows(long offset,
                                                                                                       com.google.cloud.bigquery.storage.v1beta2.ProtoRows rows,
                                                                                                       Descriptors.Descriptor descriptor)
                                                                                                throws java.lang.Exception

Append rows to a Storage API write stream at the given offset.

Throws:

java.lang.Exception

pin

void pin()

Pin this object. If close() is called before all pins are removed, the underlying resources will not be freed until all pins are removed.

unpin

void unpin()
    throws java.lang.Exception

Unpin this object. If the object has been closed, this will release any underlying resources.

Throws:

java.lang.Exception