Google BigQuery Storage v1 API - Class BigQueryRead.BigQueryReadClient (3.3.0)

public class BigQueryReadClient : ClientBase<BigQueryRead.BigQueryReadClient>

Reference documentation and code samples for the Google BigQuery Storage v1 API class BigQueryRead.BigQueryReadClient.

Client for BigQueryRead

Inheritance

Object > ClientBase > ClientBase<BigQueryRead.BigQueryReadClient> > BigQueryRead.BigQueryReadClient

Namespace

Google.Cloud.BigQuery.Storage.V1

Assembly

Google.Cloud.BigQuery.Storage.V1.dll

Constructors

BigQueryReadClient()

protected BigQueryReadClient()

Protected parameterless constructor to allow creation of test doubles.

BigQueryReadClient(CallInvoker)

public BigQueryReadClient(CallInvoker callInvoker)

Creates a new client for BigQueryRead that uses a custom CallInvoker.

Parameter
NameDescription
callInvokerCallInvoker

The callInvoker to use to make remote calls.

BigQueryReadClient(ChannelBase)

public BigQueryReadClient(ChannelBase channel)

Creates a new client for BigQueryRead

Parameter
NameDescription
channelChannelBase

The channel to use to make remote calls.

BigQueryReadClient(ClientBase.ClientBaseConfiguration)

protected BigQueryReadClient(ClientBase.ClientBaseConfiguration configuration)

Protected constructor to allow creation of configured clients.

Parameter
NameDescription
configurationClientBase.ClientBaseConfiguration

The client configuration.

Methods

CreateReadSession(CreateReadSessionRequest, CallOptions)

public virtual ReadSession CreateReadSession(CreateReadSessionRequest request, CallOptions options)

Creates a new read session. A read session divides the contents of a BigQuery table into one or more streams, which can then be used to read data from the table. The read session also specifies properties of the data to be read, such as a list of columns or a push-down filter describing the rows to be returned.

A particular row can be read by at most one stream. When the caller has reached the end of each stream in the session, then all the data in the table has been read.

Data is assigned to each stream such that roughly the same number of rows can be read from each stream. Because the server-side unit for assigning data is collections of rows, the API does not guarantee that each stream will return the same number or rows. Additionally, the limits are enforced based on the number of pre-filtered rows, so some filters can lead to lopsided assignments.

Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller.

Parameters
NameDescription
requestCreateReadSessionRequest

The request to send to the server.

optionsCallOptions

The options for the call.

Returns
TypeDescription
ReadSession

The response received from the server.

CreateReadSession(CreateReadSessionRequest, Metadata, Nullable<DateTime>, CancellationToken)

public virtual ReadSession CreateReadSession(CreateReadSessionRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))

Creates a new read session. A read session divides the contents of a BigQuery table into one or more streams, which can then be used to read data from the table. The read session also specifies properties of the data to be read, such as a list of columns or a push-down filter describing the rows to be returned.

A particular row can be read by at most one stream. When the caller has reached the end of each stream in the session, then all the data in the table has been read.

Data is assigned to each stream such that roughly the same number of rows can be read from each stream. Because the server-side unit for assigning data is collections of rows, the API does not guarantee that each stream will return the same number or rows. Additionally, the limits are enforced based on the number of pre-filtered rows, so some filters can lead to lopsided assignments.

Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller.

Parameters
NameDescription
requestCreateReadSessionRequest

The request to send to the server.

headersMetadata

The initial metadata to send with the call. This parameter is optional.

deadlineNullable<DateTime>

An optional deadline for the call. The call will be cancelled if deadline is hit.

cancellationTokenCancellationToken

An optional token for canceling the call.

Returns
TypeDescription
ReadSession

The response received from the server.

CreateReadSessionAsync(CreateReadSessionRequest, CallOptions)

public virtual AsyncUnaryCall<ReadSession> CreateReadSessionAsync(CreateReadSessionRequest request, CallOptions options)

Creates a new read session. A read session divides the contents of a BigQuery table into one or more streams, which can then be used to read data from the table. The read session also specifies properties of the data to be read, such as a list of columns or a push-down filter describing the rows to be returned.

A particular row can be read by at most one stream. When the caller has reached the end of each stream in the session, then all the data in the table has been read.

Data is assigned to each stream such that roughly the same number of rows can be read from each stream. Because the server-side unit for assigning data is collections of rows, the API does not guarantee that each stream will return the same number or rows. Additionally, the limits are enforced based on the number of pre-filtered rows, so some filters can lead to lopsided assignments.

Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller.

Parameters
NameDescription
requestCreateReadSessionRequest

The request to send to the server.

optionsCallOptions

The options for the call.

Returns
TypeDescription
AsyncUnaryCall<ReadSession>

The call object.

CreateReadSessionAsync(CreateReadSessionRequest, Metadata, Nullable<DateTime>, CancellationToken)

public virtual AsyncUnaryCall<ReadSession> CreateReadSessionAsync(CreateReadSessionRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))

Creates a new read session. A read session divides the contents of a BigQuery table into one or more streams, which can then be used to read data from the table. The read session also specifies properties of the data to be read, such as a list of columns or a push-down filter describing the rows to be returned.

A particular row can be read by at most one stream. When the caller has reached the end of each stream in the session, then all the data in the table has been read.

Data is assigned to each stream such that roughly the same number of rows can be read from each stream. Because the server-side unit for assigning data is collections of rows, the API does not guarantee that each stream will return the same number or rows. Additionally, the limits are enforced based on the number of pre-filtered rows, so some filters can lead to lopsided assignments.

Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller.

Parameters
NameDescription
requestCreateReadSessionRequest

The request to send to the server.

headersMetadata

The initial metadata to send with the call. This parameter is optional.

deadlineNullable<DateTime>

An optional deadline for the call. The call will be cancelled if deadline is hit.

cancellationTokenCancellationToken

An optional token for canceling the call.

Returns
TypeDescription
AsyncUnaryCall<ReadSession>

The call object.

NewInstance(ClientBase.ClientBaseConfiguration)

protected override BigQueryRead.BigQueryReadClient NewInstance(ClientBase.ClientBaseConfiguration configuration)

Creates a new instance of client from given ClientBaseConfiguration.

Parameter
NameDescription
configurationClientBase.ClientBaseConfiguration
Returns
TypeDescription
BigQueryRead.BigQueryReadClient
Overrides
Grpc.Core.ClientBase<Google.Cloud.BigQuery.Storage.V1.BigQueryRead.BigQueryReadClient>.NewInstance(Grpc.Core.ClientBase.ClientBaseConfiguration)

ReadRows(ReadRowsRequest, CallOptions)

public virtual AsyncServerStreamingCall<ReadRowsResponse> ReadRows(ReadRowsRequest request, CallOptions options)

Reads rows from the stream in the format prescribed by the ReadSession. Each response contains one or more table rows, up to a maximum of 100 MiB per response; read requests which attempt to read individual rows larger than 100 MiB will fail.

Each request also returns a set of stream statistics reflecting the current state of the stream.

Parameters
NameDescription
requestReadRowsRequest

The request to send to the server.

optionsCallOptions

The options for the call.

Returns
TypeDescription
AsyncServerStreamingCall<ReadRowsResponse>

The call object.

ReadRows(ReadRowsRequest, Metadata, Nullable<DateTime>, CancellationToken)

public virtual AsyncServerStreamingCall<ReadRowsResponse> ReadRows(ReadRowsRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))

Reads rows from the stream in the format prescribed by the ReadSession. Each response contains one or more table rows, up to a maximum of 100 MiB per response; read requests which attempt to read individual rows larger than 100 MiB will fail.

Each request also returns a set of stream statistics reflecting the current state of the stream.

Parameters
NameDescription
requestReadRowsRequest

The request to send to the server.

headersMetadata

The initial metadata to send with the call. This parameter is optional.

deadlineNullable<DateTime>

An optional deadline for the call. The call will be cancelled if deadline is hit.

cancellationTokenCancellationToken

An optional token for canceling the call.

Returns
TypeDescription
AsyncServerStreamingCall<ReadRowsResponse>

The call object.

SplitReadStream(SplitReadStreamRequest, CallOptions)

public virtual SplitReadStreamResponse SplitReadStream(SplitReadStreamRequest request, CallOptions options)

Splits a given ReadStream into two ReadStream objects. These ReadStream objects are referred to as the primary and the residual streams of the split. The original ReadStream can still be read from in the same manner as before. Both of the returned ReadStream objects can also be read from, and the rows returned by both child streams will be the same as the rows read from the original stream.

Moreover, the two child streams will be allocated back-to-back in the original ReadStream. Concretely, it is guaranteed that for streams original, primary, and residual, that original[0-j] = primary[0-j] and original[j-n] = residual[0-m] once the streams have been read to completion.

Parameters
NameDescription
requestSplitReadStreamRequest

The request to send to the server.

optionsCallOptions

The options for the call.

Returns
TypeDescription
SplitReadStreamResponse

The response received from the server.

SplitReadStream(SplitReadStreamRequest, Metadata, Nullable<DateTime>, CancellationToken)

public virtual SplitReadStreamResponse SplitReadStream(SplitReadStreamRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))

Splits a given ReadStream into two ReadStream objects. These ReadStream objects are referred to as the primary and the residual streams of the split. The original ReadStream can still be read from in the same manner as before. Both of the returned ReadStream objects can also be read from, and the rows returned by both child streams will be the same as the rows read from the original stream.

Moreover, the two child streams will be allocated back-to-back in the original ReadStream. Concretely, it is guaranteed that for streams original, primary, and residual, that original[0-j] = primary[0-j] and original[j-n] = residual[0-m] once the streams have been read to completion.

Parameters
NameDescription
requestSplitReadStreamRequest

The request to send to the server.

headersMetadata

The initial metadata to send with the call. This parameter is optional.

deadlineNullable<DateTime>

An optional deadline for the call. The call will be cancelled if deadline is hit.

cancellationTokenCancellationToken

An optional token for canceling the call.

Returns
TypeDescription
SplitReadStreamResponse

The response received from the server.

SplitReadStreamAsync(SplitReadStreamRequest, CallOptions)

public virtual AsyncUnaryCall<SplitReadStreamResponse> SplitReadStreamAsync(SplitReadStreamRequest request, CallOptions options)

Splits a given ReadStream into two ReadStream objects. These ReadStream objects are referred to as the primary and the residual streams of the split. The original ReadStream can still be read from in the same manner as before. Both of the returned ReadStream objects can also be read from, and the rows returned by both child streams will be the same as the rows read from the original stream.

Moreover, the two child streams will be allocated back-to-back in the original ReadStream. Concretely, it is guaranteed that for streams original, primary, and residual, that original[0-j] = primary[0-j] and original[j-n] = residual[0-m] once the streams have been read to completion.

Parameters
NameDescription
requestSplitReadStreamRequest

The request to send to the server.

optionsCallOptions

The options for the call.

Returns
TypeDescription
AsyncUnaryCall<SplitReadStreamResponse>

The call object.

SplitReadStreamAsync(SplitReadStreamRequest, Metadata, Nullable<DateTime>, CancellationToken)

public virtual AsyncUnaryCall<SplitReadStreamResponse> SplitReadStreamAsync(SplitReadStreamRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken))

Splits a given ReadStream into two ReadStream objects. These ReadStream objects are referred to as the primary and the residual streams of the split. The original ReadStream can still be read from in the same manner as before. Both of the returned ReadStream objects can also be read from, and the rows returned by both child streams will be the same as the rows read from the original stream.

Moreover, the two child streams will be allocated back-to-back in the original ReadStream. Concretely, it is guaranteed that for streams original, primary, and residual, that original[0-j] = primary[0-j] and original[j-n] = residual[0-m] once the streams have been read to completion.

Parameters
NameDescription
requestSplitReadStreamRequest

The request to send to the server.

headersMetadata

The initial metadata to send with the call. This parameter is optional.

deadlineNullable<DateTime>

An optional deadline for the call. The call will be cancelled if deadline is hit.

cancellationTokenCancellationToken

An optional token for canceling the call.

Returns
TypeDescription
AsyncUnaryCall<SplitReadStreamResponse>

The call object.