Class EnhancedBigQueryStorageStub (3.2.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
NameDescription
settingsEnhancedBigQueryStorageStubSettings
Returns
TypeDescription
EnhancedBigQueryStorageStub
Exceptions
TypeDescription
IOException

create(EnhancedBigQueryStorageStubSettings settings, BigQueryStorageSettings.RetryAttemptListener readRowsRetryAttemptListener)

public static EnhancedBigQueryStorageStub create(EnhancedBigQueryStorageStubSettings settings, BigQueryStorageSettings.RetryAttemptListener readRowsRetryAttemptListener)
Parameters
NameDescription
settingsEnhancedBigQueryStorageStubSettings
readRowsRetryAttemptListenerBigQueryStorageSettings.RetryAttemptListener
Returns
TypeDescription
EnhancedBigQueryStorageStub
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

batchCreateReadSessionStreamsCallable()

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

close()

public void close()

createReadSessionCallable()

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

finalizeStreamCallable()

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

isShutdown()

public boolean isShutdown()
Returns
TypeDescription
boolean

isTerminated()

public boolean isTerminated()
Returns
TypeDescription
boolean

readRowsCallable()

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

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

splitReadStreamCallable()

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