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()

close()

public void close()

createReadSessionCallable()

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

finalizeStreamCallable()

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

isShutdown()

public boolean isShutdown()
Returns
TypeDescription
boolean

isTerminated()

public boolean isTerminated()
Returns
TypeDescription
boolean

readRowsCallable()

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

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

splitReadStreamCallable()

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