OperationAccountant (Cloud Bigtable HBase Client for Java 0.9.7.1 API)

com.google.cloud.bigtable.grpc.async

Class OperationAccountant



  • public class OperationAccountant
    extends Object
    Throttles the number of operations that are outstanding at any point in time.
    Version:
    $Id: $Id
    Author:
    sduskis
    • Method Detail

      • registerComplexOperation

        public <T> void registerComplexOperation(long id,
                                                 OperationAccountant.ComplexOperationStalenessHandler handler)
        Registers a complex operation, like bulk mutation operations, that has a more subtle definition of success than a normal operation. Bulk mutation RPCs can have some mutations succeed and some fail; the failed mutations have to be retried in a subsequent RPC.
        Parameters:
        handler - a ComplexOperationStalenessHandler that will be periodically checked in awaitCompletion()
      • hasInflightOperations

        public boolean hasInflightOperations()

        hasInflightRequests.

        Returns:
        true if there are any outstanding requests being tracked by this OperationAccountant


Send feedback about...

Cloud Bigtable Documentation