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

Interface BigQueryServices.StorageClient

All Superinterfaces:

java.lang.AutoCloseable

Enclosing interface:

BigQueryServices

@Experimental(value=SOURCE_SINK)
public static interface BigQueryServices.StorageClient
extends java.lang.AutoCloseable

An interface representing a client object for making calls to the BigQuery Storage API.

Method Summary

Modifier and Type	Method and Description
void	close() Close the client object.
com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession	createReadSession(com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request) Create a new read session against an existing table.
java.lang.Iterable<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>	readRows(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request) Read rows in the context of a specific read stream.

Method Detail

createReadSession

com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession createReadSession(com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request)

Create a new read session against an existing table.

readRows

java.lang.Iterable<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> readRows(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request)

Read rows in the context of a specific read stream.

close

void close()

Close the client object.

The override is required since AutoCloseable allows the close method to raise an exception.

Specified by:

close in interface java.lang.AutoCloseable