RetryingReadRowsOperation (Cloud Bigtable HBase Client for Java 1.12.0 API)

Class RetryingReadRowsOperation

  • All Implemented Interfaces:

    public class RetryingReadRowsOperation
    extends AbstractRetryingOperation<,,String>
    implements ScanHandler
    An extension of AbstractRetryingOperation that manages retries for the readRows streaming RPC. This class will keep track of the last returned row key via ReadRowsRequestManager and automatically retry from the last row key .
    • Constructor Detail

      • RetryingReadRowsOperation

        public RetryingReadRowsOperation(io.grpc.stub.StreamObserver<FlatRow> observer,
                                         RetryOptions retryOptions,
                                         BigtableAsyncRpc<,> retryableRpc,
                                         io.grpc.CallOptions callOptions,
                                         ScheduledExecutorService retryExecutorService,
                                         io.grpc.Metadata originalMetadata,
    • Method Detail

      • setResultObserver

        public void setResultObserver(io.grpc.stub.StreamObserver<> resultObserver)
      • getRetryRequest

        protected getRetryRequest()
        Updates the original request via ReadRowsRequestManager.buildUpdatedRequest().
        getRetryRequest in class AbstractRetryingOperation<,,String>
      • onMessage

        public void onMessage( message)
        onMessage in class io.grpc.ClientCall.Listener<>
      • onClose

        public void onClose(io.grpc.Status status,
                            io.grpc.Metadata trailers)
        onClose in class AbstractRetryingOperation<,,String>
      • isRequestRetryable

        protected boolean isRequestRetryable()
        All read rows requests are retryable.
        isRequestRetryable in class AbstractRetryingOperation<,,String>
      • onOK

        protected boolean onOK(io.grpc.Metadata trailers)
        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<,,String>
        true if the operation was really completed.

Hai trovato utile questa pagina? Facci sapere cosa ne pensi:

Invia feedback per...

Cloud Bigtable Documentation