Class EnhancedBigQueryReadStub (3.6.0)

public class EnhancedBigQueryReadStub 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 > EnhancedBigQueryReadStub

Implements

BackgroundResource

Static Methods

create(EnhancedBigQueryReadStubSettings settings)

public static EnhancedBigQueryReadStub create(EnhancedBigQueryReadStubSettings settings)
Parameter
Name Description
settings EnhancedBigQueryReadStubSettings
Returns
Type Description
EnhancedBigQueryReadStub
Exceptions
Type Description
IOException

create(EnhancedBigQueryReadStubSettings settings, BigQueryReadSettings.RetryAttemptListener readRowsRetryAttemptListener)

public static EnhancedBigQueryReadStub create(EnhancedBigQueryReadStubSettings settings, BigQueryReadSettings.RetryAttemptListener readRowsRetryAttemptListener)
Parameters
Name Description
settings EnhancedBigQueryReadStubSettings
readRowsRetryAttemptListener BigQueryReadSettings.RetryAttemptListener
Returns
Type Description
EnhancedBigQueryReadStub
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

close()

public void close()

createReadSessionCallable()

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

isShutdown()

public boolean isShutdown()
Returns
Type Description
boolean

isTerminated()

public boolean isTerminated()
Returns
Type Description
boolean

readRowsCallable()

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

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

splitReadStreamCallable()

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