Package org.apache.hadoop.hbase.ipc
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 Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionget()
Returns the parameter passed torun(Object)
ornull
if a null value was passed.void
Called on completion of the RPC call with the response object, ornull
in the case of an error.
-
Field Details
-
result
-
resultSet
-
-
Constructor Details
-
BlockingRpcCallback
public BlockingRpcCallback()
-
-
Method Details
-
run
Called on completion of the RPC call with the response object, ornull
in the case of an error.- Specified by:
run
in interfaceorg.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<R>
- Parameters:
parameter
- the response object ornull
if an error occurred
-
get
Returns the parameter passed torun(Object)
ornull
if a null value was passed. When used asynchronously, this method will block until therun(Object)
method has been called.- Returns:
- the response object or
null
if no response was passed - Throws:
IOException
-