Package org.apache.hadoop.hbase.client

Class RegionCoprocessorRpcChannelImpl

java.lang.Object

org.apache.hadoop.hbase.client.RegionCoprocessorRpcChannelImpl

All Implemented Interfaces:

org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel

Direct Known Subclasses:

TableOverAsyncTable.RegionCoprocessorRpcChannel

@Private
class RegionCoprocessorRpcChannelImpl
extends Object
implements org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel

The implementation of a region based coprocessor rpc channel.

Field Summary

Fields

Modifier and Type	Field	Description
private final AsyncConnectionImpl	conn
private byte[]	lastRegion
private final long	operationTimeoutNs
private final RegionInfo	region
private final byte[]	row
private final long	rpcTimeoutNs
private final TableName	tableName

Constructor Summary

Constructors

Constructor	Description
RegionCoprocessorRpcChannelImpl(AsyncConnectionImpl conn, TableName tableName, RegionInfo region, byte[] row, long rpcTimeoutNs, long operationTimeoutNs)

Method Summary

Modifier and Type	Method	Description
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)
byte[]	getLastRegion()
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, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)

Methods inherited from class java.lang.Object

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

Field Details

conn

private final AsyncConnectionImpl conn

tableName

private final TableName tableName

region

private final RegionInfo region

row

private final byte[] row

rpcTimeoutNs

private final long rpcTimeoutNs

operationTimeoutNs

private final long operationTimeoutNs

lastRegion

private byte[] lastRegion

Constructor Details

RegionCoprocessorRpcChannelImpl

RegionCoprocessorRpcChannelImpl(AsyncConnectionImpl conn,
 TableName tableName,
 RegionInfo region,
 byte[] row,
 long rpcTimeoutNs,
 long operationTimeoutNs)

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,
 HRegionLocation loc,
 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 interface org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel

getLastRegion

public byte[] getLastRegion()