@Generated("by gapic-generator-java")
Package com.google.cloud.bigquery.storage.v1beta1
A client to BigQuery Storage API
The interfaces provided are listed below, along with usage samples.
======================= BaseBigQueryStorageClient =======================
Service Description: BigQuery storage API.
The BigQuery storage API can be used to read data stored in BigQuery.
The v1beta1 API is not yet officially deprecated, and will go through a full deprecation cycle (https://cloud.google.com/products#product-launch-stages) before the service is turned down. However, new code should use the v1 API going forward.
Sample for BaseBigQueryStorageClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try (BaseBigQueryStorageClient baseBigQueryStorageClient = BaseBigQueryStorageClient.create()) {
TableReferenceProto.TableReference tableReference =
TableReferenceProto.TableReference.newBuilder().build();
ProjectName parent = ProjectName.of("[PROJECT]");
int requestedStreams = 1017221410;
Storage.ReadSession response =
baseBigQueryStorageClient.createReadSession(tableReference, parent, requestedStreams);
}
-
Class Summary Class Description ArrowProto ArrowProto.ArrowRecordBatch Arrow RecordBatch.ArrowProto.ArrowRecordBatch.Builder Arrow RecordBatch.ArrowProto.ArrowSchema Arrow schema.ArrowProto.ArrowSchema.Builder Arrow schema.AvroProto AvroProto.AvroRows Avro rows.AvroProto.AvroRows.Builder Avro rows.AvroProto.AvroSchema Avro schema.AvroProto.AvroSchema.Builder Avro schema.BaseBigQueryStorageClient Service Description: BigQuery storage API.BaseBigQueryStorageSettings Settings class to configure an instance ofBaseBigQueryStorageClient
.BaseBigQueryStorageSettings.Builder Builder for BaseBigQueryStorageSettings.BigQueryStorageClient Service Description: BigQuery storage API.BigQueryStorageGrpc BigQuery storage API.BigQueryStorageGrpc.BigQueryStorageBlockingStub A stub to allow clients to do synchronous rpc calls to service BigQueryStorage.BigQueryStorageGrpc.BigQueryStorageFutureStub A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryStorage.BigQueryStorageGrpc.BigQueryStorageImplBase Base class for the server implementation of the service BigQueryStorage.BigQueryStorageGrpc.BigQueryStorageStub A stub to allow clients to do asynchronous rpc calls to service BigQueryStorage.BigQueryStorageSettings Settings class to configure an instance ofBigQueryStorageClient
.BigQueryStorageSettings.Builder Builder for BigQueryStorageSettings.ProjectName ProjectName.Builder Builder for projects/{project}.ReadOptions ReadOptions.TableReadOptions Options dictating how we read a table.ReadOptions.TableReadOptions.Builder Options dictating how we read a table.Storage Storage.BatchCreateReadSessionStreamsRequest Information needed to request additional streams for an established read session.Storage.BatchCreateReadSessionStreamsRequest.Builder Information needed to request additional streams for an established read session.Storage.BatchCreateReadSessionStreamsResponse The response from `BatchCreateReadSessionStreams` returns the stream identifiers for the newly created streams.Storage.BatchCreateReadSessionStreamsResponse.Builder The response from `BatchCreateReadSessionStreams` returns the stream identifiers for the newly created streams.Storage.CreateReadSessionRequest Creates a new read session, which may include additional options such as requested parallelism, projection filters and constraints.Storage.CreateReadSessionRequest.Builder Creates a new read session, which may include additional options such as requested parallelism, projection filters and constraints.Storage.FinalizeStreamRequest Request information for invoking `FinalizeStream`.Storage.FinalizeStreamRequest.Builder Request information for invoking `FinalizeStream`.Storage.Progress Protobuf typegoogle.cloud.bigquery.storage.v1beta1.Progress
Storage.Progress.Builder Protobuf typegoogle.cloud.bigquery.storage.v1beta1.Progress
Storage.ReadRowsRequest Requesting row data via `ReadRows` must provide Stream position information.Storage.ReadRowsRequest.Builder Requesting row data via `ReadRows` must provide Stream position information.Storage.ReadRowsResponse Response from calling `ReadRows` may include row data, progress and throttling information.Storage.ReadRowsResponse.Builder Response from calling `ReadRows` may include row data, progress and throttling information.Storage.ReadSession Information returned from a `CreateReadSession` request.Storage.ReadSession.Builder Information returned from a `CreateReadSession` request.Storage.SplitReadStreamRequest Request information for `SplitReadStream`.Storage.SplitReadStreamRequest.Builder Request information for `SplitReadStream`.Storage.SplitReadStreamResponse Response from `SplitReadStream`.Storage.SplitReadStreamResponse.Builder Response from `SplitReadStream`.Storage.Stream Information about a single data stream within a read session.Storage.Stream.Builder Information about a single data stream within a read session.Storage.StreamPosition Expresses a point within a given stream using an offset position.Storage.StreamPosition.Builder Expresses a point within a given stream using an offset position.Storage.StreamStatus Progress information for a given Stream.Storage.StreamStatus.Builder Progress information for a given Stream.Storage.ThrottleStatus Information on if the current connection is being throttled.Storage.ThrottleStatus.Builder Information on if the current connection is being throttled.TableReferenceProto TableReferenceProto.TableModifiers All fields in this message optional.TableReferenceProto.TableModifiers.Builder All fields in this message optional.TableReferenceProto.TableReference Table reference that includes just the 3 strings needed to identify a table.TableReferenceProto.TableReference.Builder Table reference that includes just the 3 strings needed to identify a table. -
Enum Summary Enum Description Storage.DataFormat Data format for input or output data.Storage.ReadRowsResponse.RowsCase Storage.ReadRowsResponse.SchemaCase Storage.ReadSession.SchemaCase Storage.ShardingStrategy Strategy for distributing data among multiple streams in a read session.