AbstractRetryingOperation (Cloud Bigtable HBase Client for Java 0.9.7.1 API)

com.google.cloud.bigtable.grpc.async

Class AbstractRetryingOperation<RequestT,ResponseT,ResultT>

  • java.lang.Object
    • io.grpc.ClientCall.Listener<ResponseT>
      • com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation<RequestT,ResponseT,ResultT>
    • Method Detail

      • onClose

        public void onClose(io.grpc.Status status,
                            io.grpc.Metadata trailers)
        Overrides:
        onClose in class io.grpc.ClientCall.Listener<ResponseT>
      • getRunnable

        protected Runnable getRunnable()
      • isRequestRetryable

        protected boolean isRequestRetryable()
      • setException

        protected void setException(Exception exception)
      • onOK

        protected abstract void onOK()
        A subclass has the opportunity to perform the final operations it needs now that the RPC is successfully complete.
      • run

        protected void run()

        Calls BigtableAsyncRpc#newCall(CallOptions) and BigtableAsyncRpc#start(ClientCall, Object, io.grpc.ClientCall.Listener, Metadata) with this as the listener so that retries happen correctly.

      • getRetryRequest

        protected RequestT getRetryRequest()
      • cancel

        public void cancel()
        Cancels the RPC.
      • getBlockingResult

        public ResultT getBlockingResult()
      • cancel

        protected void cancel(String message)
        Cancels the RPC with a specific message.
        Parameters:
        message -


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Bigtable Documentation