com.google.cloud.bigtable.data.v2.stub.sql

Class ExecuteQueryResumptionStrategy

java.lang.Object

com.google.cloud.bigtable.data.v2.stub.sql.ExecuteQueryResumptionStrategy

All Implemented Interfaces:

com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse>

@InternalApi
public class ExecuteQueryResumptionStrategy
extends Object
implements com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse>

Constructor Summary

Constructors

Constructor and Description
ExecuteQueryResumptionStrategy()

Method Summary

Modifier and Type	Method and Description
boolean	canResume()
com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse>	createNew()
ExecuteQueryCallContext	getResumeRequest(ExecuteQueryCallContext originalRequest)
ExecuteQueryResponse	processResponse(ExecuteQueryResponse response)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecuteQueryResumptionStrategy

public ExecuteQueryResumptionStrategy()

Method Detail

createNew

@Nonnull
public com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse> createNew()

Specified by:

createNew in interface com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse>

processResponse

@Nonnull
public ExecuteQueryResponse processResponse(ExecuteQueryResponse response)

Specified by:

processResponse in interface com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse>

getResumeRequest

@Nullable
public ExecuteQueryCallContext getResumeRequest(ExecuteQueryCallContext originalRequest)

Specified by:

getResumeRequest in interface com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse>

canResume

public boolean canResume()

Specified by:

canResume in interface com.google.api.gax.retrying.StreamResumptionStrategy<ExecuteQueryCallContext,ExecuteQueryResponse>