RetryingMutateRowsOperation (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.async

Class RetryingMutateRowsOperation

    • Constructor Detail

      • RetryingMutateRowsOperation

        public RetryingMutateRowsOperation(RetryOptions retryOptions,
                                           com.google.bigtable.v2.MutateRowsRequest originalRequest,
                                           BigtableAsyncRpc<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse> retryableRpc,
                                           io.grpc.CallOptions callOptions,
                                           ScheduledExecutorService retryExecutorService,
                                           io.grpc.Metadata originalMetadata,
                                           com.google.api.core.ApiClock clock)
    • Method Detail

      • onMessage

        public void onMessage(com.google.bigtable.v2.MutateRowsResponse message)
        Overrides:
        onMessage in class io.grpc.ClientCall.Listener<com.google.bigtable.v2.MutateRowsResponse>
      • getRetryRequest

        protected com.google.bigtable.v2.MutateRowsRequest getRetryRequest()
        Overrides:
        getRetryRequest in class AbstractRetryingOperation<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse,List<com.google.bigtable.v2.MutateRowsResponse>>
      • onOK

        protected boolean onOK(io.grpc.Metadata trailers)
        Description copied from class: AbstractRetryingOperation
        A subclass has the opportunity to perform the final operations it needs now that the RPC is successfully complete. If a subclass has to retry, due to the message, this method will return false
        Specified by:
        onOK in class AbstractRetryingOperation<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse,List<com.google.bigtable.v2.MutateRowsResponse>>
        Returns:
        true if the operation was really completed.