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

Class EnhancedBigQueryStorageStub

java.lang.Object

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

All Implemented Interfaces:

com.google.api.gax.core.BackgroundResource, AutoCloseable

public class EnhancedBigQueryStorageStub
extends Object
implements com.google.api.gax.core.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)
com.google.api.gax.rpc.UnaryCallable<Storage.BatchCreateReadSessionStreamsRequest,Storage.BatchCreateReadSessionStreamsResponse>	batchCreateReadSessionStreamsCallable()
void	close()
static EnhancedBigQueryStorageStub	create(EnhancedBigQueryStorageStubSettings settings)
static EnhancedBigQueryStorageStub	create(EnhancedBigQueryStorageStubSettings settings, BigQueryStorageSettings.RetryAttemptListener readRowsRetryAttemptListener)
com.google.api.gax.rpc.UnaryCallable<Storage.CreateReadSessionRequest,Storage.ReadSession>	createReadSessionCallable()
com.google.api.gax.rpc.UnaryCallable<Storage.FinalizeStreamRequest,com.google.protobuf.Empty>	finalizeStreamCallable()
boolean	isShutdown()
boolean	isTerminated()
com.google.api.gax.rpc.ServerStreamingCallable<Storage.ReadRowsRequest,Storage.ReadRowsResponse>	readRowsCallable()
void	shutdown()
void	shutdownNow()
com.google.api.gax.rpc.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 Detail

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 com.google.api.gax.rpc.UnaryCallable<Storage.CreateReadSessionRequest,Storage.ReadSession> createReadSessionCallable()

readRowsCallable

public com.google.api.gax.rpc.ServerStreamingCallable<Storage.ReadRowsRequest,Storage.ReadRowsResponse> readRowsCallable()

batchCreateReadSessionStreamsCallable

public com.google.api.gax.rpc.UnaryCallable<Storage.BatchCreateReadSessionStreamsRequest,Storage.BatchCreateReadSessionStreamsResponse> batchCreateReadSessionStreamsCallable()

finalizeStreamCallable

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

splitReadStreamCallable

public com.google.api.gax.rpc.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 com.google.api.gax.core.BackgroundResource

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface com.google.api.gax.core.BackgroundResource

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface com.google.api.gax.core.BackgroundResource

shutdownNow

public void shutdownNow()

Specified by:

shutdownNow in interface com.google.api.gax.core.BackgroundResource

awaitTermination

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

Specified by:

awaitTermination in interface com.google.api.gax.core.BackgroundResource

Throws:

InterruptedException