Package org.apache.hadoop.hbase.client
Class RegionServerCoprocessorRpcChannelImpl
java.lang.Object
org.apache.hadoop.hbase.client.RegionServerCoprocessorRpcChannelImpl
- All Implemented Interfaces:
org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel
@Private
public class RegionServerCoprocessorRpcChannelImpl
extends Object
implements org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel
The implementation of a region server based coprocessor rpc channel.
-
Field Summary
Modifier and TypeFieldDescription(package private) AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<org.apache.hbase.thirdparty.com.google.protobuf.Message>
-
Constructor Summary
ConstructorDescriptionRegionServerCoprocessorRpcChannelImpl
(AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<org.apache.hbase.thirdparty.com.google.protobuf.Message> callerBuilder) -
Method Summary
Modifier and TypeMethodDescriptionvoid
callMethod
(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor method, org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message responsePrototype, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hbase.thirdparty.com.google.protobuf.Message> done) private CompletableFuture<org.apache.hbase.thirdparty.com.google.protobuf.Message>
rpcCall
(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor method, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message responsePrototype, HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
-
Field Details
-
callerBuilder
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<org.apache.hbase.thirdparty.com.google.protobuf.Message> callerBuilder
-
-
Constructor Details
-
RegionServerCoprocessorRpcChannelImpl
RegionServerCoprocessorRpcChannelImpl(AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<org.apache.hbase.thirdparty.com.google.protobuf.Message> callerBuilder)
-
-
Method Details
-
rpcCall
private CompletableFuture<org.apache.hbase.thirdparty.com.google.protobuf.Message> rpcCall(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor method, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message responsePrototype, HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub) -
callMethod
public void callMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor method, org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message responsePrototype, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hbase.thirdparty.com.google.protobuf.Message> done) - Specified by:
callMethod
in interfaceorg.apache.hbase.thirdparty.com.google.protobuf.RpcChannel
-