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

Class EnhancedBigQueryReadStub

java.lang.Object

com.google.cloud.bigquery.storage.v1beta2.stub.EnhancedBigQueryReadStub

All Implemented Interfaces:

BackgroundResource, AutoCloseable

public class EnhancedBigQueryReadStub
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)
void	close()
static EnhancedBigQueryReadStub	create(EnhancedBigQueryReadStubSettings settings)
static EnhancedBigQueryReadStub	create(EnhancedBigQueryReadStubSettings settings, BigQueryReadSettings.RetryAttemptListener readRowsRetryAttemptListener)
UnaryCallable<CreateReadSessionRequest,ReadSession>	createReadSessionCallable()
boolean	isShutdown()
boolean	isTerminated()
ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>	readRowsCallable()
void	shutdown()
void	shutdownNow()
UnaryCallable<SplitReadStreamRequest,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 EnhancedBigQueryReadStub create(EnhancedBigQueryReadStubSettings settings)
                                       throws IOException

Throws:

IOException

create

public static EnhancedBigQueryReadStub create(EnhancedBigQueryReadStubSettings settings,
 BigQueryReadSettings.RetryAttemptListener readRowsRetryAttemptListener)
                                       throws IOException

Throws:

IOException

createReadSessionCallable

public UnaryCallable<CreateReadSessionRequest,ReadSession> createReadSessionCallable()

readRowsCallable

public ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse> readRowsCallable()

splitReadStreamCallable

public UnaryCallable<SplitReadStreamRequest,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