Package com.google.cloud.bigquery.storage.v1beta1.stub

Class EnhancedBigQueryStorageStub

java.lang.Object

com.google.cloud.bigquery.storage.v1beta1.stub.EnhancedBigQueryStorageStub

All Implemented Interfaces:

BackgroundResource, AutoCloseable

public class EnhancedBigQueryStorageStub
extends Object
implements BackgroundResource

Enhanced stub class for BigQuery Storage API.

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

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long duration, TimeUnit unit)
UnaryCallable<Storage.BatchCreateReadSessionStreamsRequest,Storage.BatchCreateReadSessionStreamsResponse>	batchCreateReadSessionStreamsCallable()
void	close()
static EnhancedBigQueryStorageStub	create(EnhancedBigQueryStorageStubSettings settings)
static EnhancedBigQueryStorageStub	create(EnhancedBigQueryStorageStubSettings settings, BigQueryStorageSettings.RetryAttemptListener readRowsRetryAttemptListener)
UnaryCallable<Storage.CreateReadSessionRequest,Storage.ReadSession>	createReadSessionCallable()
UnaryCallable<Storage.FinalizeStreamRequest,com.google.protobuf.Empty>	finalizeStreamCallable()
boolean	isShutdown()
boolean	isTerminated()
ServerStreamingCallable<Storage.ReadRowsRequest,Storage.ReadRowsResponse>	readRowsCallable()
void	shutdown()
void	shutdownNow()
UnaryCallable<Storage.SplitReadStreamRequest,Storage.SplitReadStreamResponse>	splitReadStreamCallable()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static EnhancedBigQueryStorageStub create(EnhancedBigQueryStorageStubSettings settings)
                                          throws IOException

Throws:

IOException

create

public static EnhancedBigQueryStorageStub create(EnhancedBigQueryStorageStubSettings settings,
 BigQueryStorageSettings.RetryAttemptListener readRowsRetryAttemptListener)
                                          throws IOException

Throws:

IOException

createReadSessionCallable

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

readRowsCallable

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

batchCreateReadSessionStreamsCallable

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

finalizeStreamCallable

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

splitReadStreamCallable

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

close

public void close()

Specified by:

close in interface AutoCloseable

shutdown

public void shutdown()

Specified by:

shutdown in interface BackgroundResource

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface BackgroundResource

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface BackgroundResource

shutdownNow

public void shutdownNow()

Specified by:

shutdownNow in interface BackgroundResource

awaitTermination

public boolean awaitTermination(long duration,
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface BackgroundResource

Throws:

InterruptedException