Package org.apache.hadoop.hbase.ipc
Class AbstractRpcClient.BlockingRpcChannelImplementation
java.lang.Object
org.apache.hadoop.hbase.ipc.AbstractRpcClient.AbstractRpcChannel
org.apache.hadoop.hbase.ipc.AbstractRpcClient.BlockingRpcChannelImplementation
- All Implemented Interfaces:
org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel
- Enclosing class:
- AbstractRpcClient<T extends RpcConnection>
public static class AbstractRpcClient.BlockingRpcChannelImplementation
extends AbstractRpcClient.AbstractRpcChannel
implements org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel
Blocking rpc channel that goes via hbase rpc.
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient.AbstractRpcChannel
addr, rpcClient, rpcTimeout, ticket
-
Constructor Summary
ModifierConstructorDescriptionprotected
BlockingRpcChannelImplementation
(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.hbase.thirdparty.com.google.protobuf.Message
callBlockingMethod
(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hbase.thirdparty.com.google.protobuf.Message param, org.apache.hbase.thirdparty.com.google.protobuf.Message returnType) Methods inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient.AbstractRpcChannel
configureRpcController
-
Constructor Details
-
BlockingRpcChannelImplementation
protected BlockingRpcChannelImplementation(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout)
-
-
Method Details
-
callBlockingMethod
public org.apache.hbase.thirdparty.com.google.protobuf.Message callBlockingMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hbase.thirdparty.com.google.protobuf.Message param, org.apache.hbase.thirdparty.com.google.protobuf.Message returnType) throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException - Specified by:
callBlockingMethod
in interfaceorg.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel
- Throws:
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
-