org.apache.hadoop.hbase.client

Class RegionCoprocessorRpcChannel

java.lang.Object

org.apache.hadoop.hbase.client.SyncCoprocessorRpcChannel

org.apache.hadoop.hbase.client.RegionCoprocessorRpcChannel

All Implemented Interfaces:

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

@InterfaceAudience.Private
class RegionCoprocessorRpcChannel
extends SyncCoprocessorRpcChannel

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 Table.coprocessorService(byte[]), but should normally only be used in creating a new Service stub to call the endpoint methods.

See Also:

Table.coprocessorService(byte[])

Field Summary

Fields

Modifier and Type	Field and Description
private ClusterConnection	conn
private byte[]	lastRegion
private static org.slf4j.Logger	LOG
private int	operationTimeout
private byte[]	row
private RpcRetryingCallerFactory	rpcCallerFactory
private TableName	table

Constructor Summary

Constructors

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

Method Summary

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() Get last region this RpcChannel communicated with

Methods inherited from class org.apache.hadoop.hbase.client.SyncCoprocessorRpcChannel

callBlockingMethod, callMethod

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

table

private final TableName table

row

private final byte[] row

conn

private final ClusterConnection conn

lastRegion

private byte[] lastRegion

operationTimeout

private final int operationTimeout

rpcCallerFactory

private final RpcRetryingCallerFactory rpcCallerFactory

Constructor Detail

RegionCoprocessorRpcChannel

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

Constructor

Parameters:

conn - connection to use

table - to connect to

row - to locate region with

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 SyncCoprocessorRpcChannel

Throws:

IOException

getLastRegion

public byte[] getLastRegion()

Get last region this RpcChannel communicated with

Returns:

region name as byte array