Class CoprocessorRpcUtils.BlockingRpcCallback<R>

java.lang.Object
org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils.BlockingRpcCallback<R>
All Implemented Interfaces:
org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<R>
Enclosing class:
CoprocessorRpcUtils

@Private public static class CoprocessorRpcUtils.BlockingRpcCallback<R> extends Object implements org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<R>
Simple RpcCallback implementation providing a Future-like get() method, which will block util the instance's run(Object) method has been called. R is the RPC response type that will be passed to the run(Object) method.
  • Field Details

  • Constructor Details

  • Method Details

    • run

      public void run(R parameter)
      Called on completion of the RPC call with the response object, or null in the case of an error.
      Specified by:
      run in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<R>
      Parameters:
      parameter - the response object or null if an error occurred
    • get

      public R get() throws IOException
      Returns the parameter passed to run(Object) or null if a null value was passed. When used asynchronously, this method will block until the run(Object) method has been called.
      Returns:
      the response object or null if no response was passed
      Throws:
      IOException