Class EnhancedBigQueryStorageStub (3.6.0)

public class EnhancedBigQueryStorageStub implements BackgroundResource

Enhanced stub class for BigQuery Storage API.

This class is for advanced usage and reflects the underlying API directly.

Inheritance

java.lang.Object > EnhancedBigQueryStorageStub

Implements

BackgroundResource

Static Methods

create(EnhancedBigQueryStorageStubSettings settings)

public static EnhancedBigQueryStorageStub create(EnhancedBigQueryStorageStubSettings settings)
Parameter
Name Description
settings EnhancedBigQueryStorageStubSettings
Returns
Type Description
EnhancedBigQueryStorageStub
Exceptions
Type Description
IOException

create(EnhancedBigQueryStorageStubSettings settings, BigQueryStorageSettings.RetryAttemptListener readRowsRetryAttemptListener)

public static EnhancedBigQueryStorageStub create(EnhancedBigQueryStorageStubSettings settings, BigQueryStorageSettings.RetryAttemptListener readRowsRetryAttemptListener)
Parameters
Name Description
settings EnhancedBigQueryStorageStubSettings
readRowsRetryAttemptListener BigQueryStorageSettings.RetryAttemptListener
Returns
Type Description
EnhancedBigQueryStorageStub
Exceptions
Type Description
IOException

Methods

awaitTermination(long duration, TimeUnit unit)

public boolean awaitTermination(long duration, TimeUnit unit)
Parameters
Name Description
duration long
unit TimeUnit
Returns
Type Description
boolean
Exceptions
Type Description
InterruptedException

batchCreateReadSessionStreamsCallable()

public UnaryCallable<Storage.BatchCreateReadSessionStreamsRequest,Storage.BatchCreateReadSessionStreamsResponse> batchCreateReadSessionStreamsCallable()
Returns
Type Description
UnaryCallable<BatchCreateReadSessionStreamsRequest,BatchCreateReadSessionStreamsResponse>

close()

public void close()

createReadSessionCallable()

public UnaryCallable<Storage.CreateReadSessionRequest,Storage.ReadSession> createReadSessionCallable()
Returns
Type Description
UnaryCallable<CreateReadSessionRequest,ReadSession>

finalizeStreamCallable()

public UnaryCallable<Storage.FinalizeStreamRequest,Empty> finalizeStreamCallable()
Returns
Type Description
UnaryCallable<FinalizeStreamRequest,Empty>

isShutdown()

public boolean isShutdown()
Returns
Type Description
boolean

isTerminated()

public boolean isTerminated()
Returns
Type Description
boolean

readRowsCallable()

public ServerStreamingCallable<Storage.ReadRowsRequest,Storage.ReadRowsResponse> readRowsCallable()
Returns
Type Description
ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

splitReadStreamCallable()

public UnaryCallable<Storage.SplitReadStreamRequest,Storage.SplitReadStreamResponse> splitReadStreamCallable()
Returns
Type Description
UnaryCallable<SplitReadStreamRequest,SplitReadStreamResponse>