Class EnhancedBigQueryReadStub (3.1.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
NameDescription
settingsEnhancedBigQueryReadStubSettings
Returns
TypeDescription
EnhancedBigQueryReadStub
Exceptions
TypeDescription
IOException

create(EnhancedBigQueryReadStubSettings settings, BigQueryReadSettings.RetryAttemptListener readRowsRetryAttemptListener)

public static EnhancedBigQueryReadStub create(EnhancedBigQueryReadStubSettings settings, BigQueryReadSettings.RetryAttemptListener readRowsRetryAttemptListener)
Parameters
NameDescription
settingsEnhancedBigQueryReadStubSettings
readRowsRetryAttemptListenerBigQueryReadSettings.RetryAttemptListener
Returns
TypeDescription
EnhancedBigQueryReadStub
Exceptions
TypeDescription
IOException

Methods

awaitTermination(long duration, TimeUnit unit)

public boolean awaitTermination(long duration, TimeUnit unit)
Parameters
NameDescription
durationlong
unitTimeUnit
Returns
TypeDescription
boolean
Exceptions
TypeDescription
InterruptedException

close()

public void close()

createReadSessionCallable()

public UnaryCallable<CreateReadSessionRequest,ReadSession> createReadSessionCallable()
Returns
TypeDescription
UnaryCallable<CreateReadSessionRequest,ReadSession>

isShutdown()

public boolean isShutdown()
Returns
TypeDescription
boolean

isTerminated()

public boolean isTerminated()
Returns
TypeDescription
boolean

readRowsCallable()

public ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse> readRowsCallable()
Returns
TypeDescription
ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

splitReadStreamCallable()

public UnaryCallable<SplitReadStreamRequest,SplitReadStreamResponse> splitReadStreamCallable()
Returns
TypeDescription
UnaryCallable<SplitReadStreamRequest,SplitReadStreamResponse>