org.apache.hadoop.hbase.client

Class RegionCoprocessorRpcChannelImpl

java.lang.Object

org.apache.hadoop.hbase.client.RegionCoprocessorRpcChannelImpl

All Implemented Interfaces:

com.google.protobuf.RpcChannel

@InterfaceAudience.Private
class RegionCoprocessorRpcChannelImpl
extends Object
implements com.google.protobuf.RpcChannel

The implementation of a region based coprocessor rpc channel.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
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> done)
private CompletableFuture<com.google.protobuf.Message>	rpcCall(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, 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 Detail

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

Constructor Detail

RegionCoprocessorRpcChannelImpl

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

Method Detail

rpcCall

private CompletableFuture<com.google.protobuf.Message> rpcCall(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                               com.google.protobuf.Message request,
                                                               com.google.protobuf.Message responsePrototype,
                                                               HBaseRpcController controller,
                                                               HRegionLocation loc,
                                                               org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)

callMethod

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> done)

Specified by:

callMethod in interface com.google.protobuf.RpcChannel