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

Interface BigQueryServices.StorageClient

All Superinterfaces:

java.lang.AutoCloseable

Enclosing interface:

BigQueryServices

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.
ReadSession	createReadSession(CreateReadSessionRequest request) Create a new read session against an existing table.
BigQueryServices.BigQueryServerStream<ReadRowsResponse>	readRows(ReadRowsRequest request) Read rows in the context of a specific read stream.
SplitReadStreamResponse	splitReadStream(SplitReadStreamRequest request)

Method Detail

createReadSession

ReadSession createReadSession(CreateReadSessionRequest request)

Create a new read session against an existing table.

readRows

BigQueryServices.BigQueryServerStream<ReadRowsResponse> readRows(ReadRowsRequest request)

Read rows in the context of a specific read stream.

splitReadStream

SplitReadStreamResponse splitReadStream(SplitReadStreamRequest request)

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