org.apache.hadoop.hbase.client

Class SyncCoprocessorRpcChannel

java.lang.Object

org.apache.hadoop.hbase.client.SyncCoprocessorRpcChannel

All Implemented Interfaces:

com.google.protobuf.BlockingRpcChannel, com.google.protobuf.RpcChannel, CoprocessorRpcChannel

Direct Known Subclasses:

RegionCoprocessorRpcChannel

@InterfaceAudience.Public
abstract class SyncCoprocessorRpcChannel
extends Object
implements CoprocessorRpcChannel

Base class which provides clients with an RPC connection to call coprocessor endpoint Services. Note that clients should not use this class directly, except through Table.coprocessorService(byte[]).

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
SyncCoprocessorRpcChannel()

Method Summary

Modifier and Type	Method and Description
com.google.protobuf.Message	callBlockingMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype)
protected abstract com.google.protobuf.Message	callExecService(com.google.protobuf.RpcController controller, com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype)
void	callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype, com.google.protobuf.RpcCallback<com.google.protobuf.Message> callback)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

SyncCoprocessorRpcChannel

SyncCoprocessorRpcChannel()

Method Detail

callMethod

@InterfaceAudience.Private
public void callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                  com.google.protobuf.RpcController controller,
                                                  com.google.protobuf.Message request,
                                                  com.google.protobuf.Message responsePrototype,
                                                  com.google.protobuf.RpcCallback<com.google.protobuf.Message> callback)

Specified by:

callMethod in interface com.google.protobuf.RpcChannel

callBlockingMethod

@InterfaceAudience.Private
public com.google.protobuf.Message callBlockingMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                                                 com.google.protobuf.RpcController controller,
                                                                                 com.google.protobuf.Message request,
                                                                                 com.google.protobuf.Message responsePrototype)
                                                                          throws com.google.protobuf.ServiceException

Specified by:

callBlockingMethod in interface com.google.protobuf.BlockingRpcChannel

Throws:

com.google.protobuf.ServiceException

callExecService

protected abstract com.google.protobuf.Message callExecService(com.google.protobuf.RpcController controller,
                                                               com.google.protobuf.Descriptors.MethodDescriptor method,
                                                               com.google.protobuf.Message request,
                                                               com.google.protobuf.Message responsePrototype)
                                                        throws IOException

Throws:

IOException