Class AwaitConsistencyCallableV2 (2.79.0) 

public class AwaitConsistencyCallableV2 extends UnaryCallable<ConsistencyRequest,Void>

Decoupled modern consistency polling callable for V2 client.

This callable waits until either replication or Data Boost has caught up to the point it was called. It wraps GenerateConsistencyToken and CheckConsistency RPCs.

Inheritance

java.lang.Object > UnaryCallable > AwaitConsistencyCallableV2

Static Methods

create(UnaryCallable<GenerateConsistencyTokenRequest,GenerateConsistencyTokenResponse> generateCallable, UnaryCallable<CheckConsistencyRequest,CheckConsistencyResponse> checkCallable, ApiClock clock, ScheduledExecutorService executor, RetrySettings pollingSettings)

public static AwaitConsistencyCallableV2 create(UnaryCallable<GenerateConsistencyTokenRequest,GenerateConsistencyTokenResponse> generateCallable, UnaryCallable<CheckConsistencyRequest,CheckConsistencyResponse> checkCallable, ApiClock clock, ScheduledExecutorService executor, RetrySettings pollingSettings)
Parameters
Name Description
generateCallable UnaryCallable<com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest,com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse>
checkCallable UnaryCallable<com.google.bigtable.admin.v2.CheckConsistencyRequest,com.google.bigtable.admin.v2.CheckConsistencyResponse>
clock ApiClock
executor ScheduledExecutorService
pollingSettings RetrySettings
Returns
Type Description
AwaitConsistencyCallableV2

Methods

futureCall(ConsistencyRequest consistencyRequest, ApiCallContext apiCallContext)

public ApiFuture<Void> futureCall(ConsistencyRequest consistencyRequest, ApiCallContext apiCallContext)
Parameters
Name Description
consistencyRequest ConsistencyRequest
apiCallContext ApiCallContext
Returns
Type Description
ApiFuture<Void>
Overrides