org.apache.hadoop.hbase.ipc

Class RegionCoprocessorRpcChannel

java.lang.Object

org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel

org.apache.hadoop.hbase.ipc.RegionCoprocessorRpcChannel

All Implemented Interfaces:

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

@InterfaceAudience.Private
public class RegionCoprocessorRpcChannel
extends CoprocessorRpcChannel

Provides clients with an RPC connection to call coprocessor endpoint Services against a given table region. An instance of this class may be obtained by calling HTable.coprocessorService(byte[]), but should normally only be used in creating a new Service stub to call the endpoint methods.

See Also:

HTable.coprocessorService(byte[])

Constructor Summary

Constructors

Constructor and Description
RegionCoprocessorRpcChannel(ClusterConnection conn, TableName table, byte[] row)

Method Summary

Methods

Modifier and Type	Method and Description
protected 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)
byte[]	getLastRegion()

Methods inherited from class org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel

callBlockingMethod, callMethod

Methods inherited from class java.lang.Object

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

Constructor Detail

RegionCoprocessorRpcChannel

public RegionCoprocessorRpcChannel(ClusterConnection conn,
                           TableName table,
                           byte[] row)

Method Detail

callExecService

protected 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

Specified by:

callExecService in class CoprocessorRpcChannel

Throws:

IOException

getLastRegion

public byte[] getLastRegion()