Package com.google.cloud.bigquery.storage.v1.stub.readrows

Class ReadRowsRetryingCallable

java.lang.Object

com.google.api.gax.rpc.ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>

com.google.cloud.bigquery.storage.v1.stub.readrows.ReadRowsRetryingCallable

public final class ReadRowsRetryingCallable
extends ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>

Constructor Summary

Constructors

Constructor	Description
ReadRowsRetryingCallable(ApiCallContext context, ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse> innerCallable, ScheduledRetryingExecutor<Void> executor, StreamResumptionStrategy<ReadRowsRequest,ReadRowsResponse> resumptionStrategyPrototype)

Method Summary

Modifier and Type	Method	Description
void	call(ReadRowsRequest request, ResponseObserver<ReadRowsResponse> responseObserver, ApiCallContext context)

Methods inherited from class com.google.api.gax.rpc.ServerStreamingCallable

all, blockingServerStreamingCall, blockingServerStreamingCall, call, call, call, first, serverStreamingCall, serverStreamingCall, withDefaultCallContext

Methods inherited from class java.lang.Object

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

Constructor Details

ReadRowsRetryingCallable

public ReadRowsRetryingCallable(ApiCallContext context,
 ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse> innerCallable,
 ScheduledRetryingExecutor<Void> executor,
 StreamResumptionStrategy<ReadRowsRequest,ReadRowsResponse> resumptionStrategyPrototype)

Method Details

call

public void call(ReadRowsRequest request,
 ResponseObserver<ReadRowsResponse> responseObserver,
 ApiCallContext context)

Specified by:

call in class ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>