Package 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

@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	Description
private final ClusterConnection	conn
private byte[]	lastRegion
private static final org.slf4j.Logger	LOG
private final int	operationTimeout
private final Map<String,byte[]>	requestAttributes
private final byte[]	row
private final RpcRetryingCallerFactory	rpcCallerFactory
private final TableName	table

Constructor Summary

Constructors

Constructor	Description
RegionCoprocessorRpcChannel(ClusterConnection conn, TableName table, byte[] row, Map<String,byte[]> requestAttributes)	Constructor

Method Summary

Modifier and Type	Method	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 Details

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

requestAttributes

private final Map<String,byte[]> requestAttributes

Constructor Details

RegionCoprocessorRpcChannel

RegionCoprocessorRpcChannel(ClusterConnection conn,
 TableName table,
 byte[] row,
 Map<String,byte[]> requestAttributes)

Constructor

Parameters:

conn - connection to use

table - to connect to

row - to locate region with

Method Details

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