OperationAccountant (Cloud Bigtable HBase Client for Java 1.12.0 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
    • Constructor Detail

    • Method Detail

      • registerOperation

        public void registerOperation(ListenableFuture<?> future)
        Register a new RPC operation. Blocks until the requested resources are available. This method must be paired with a call to onOperationCompletion().
      • hasInflightOperations

        public boolean hasInflightOperations()
        hasInflightRequests.
        Returns:
        true if there are any outstanding requests being tracked by this OperationAccountant