org.apache.hadoop.hbase.client

Class NoncedRegionServerCallable<T>

java.lang.Object

org.apache.hadoop.hbase.client.RegionServerCallable<T,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>

org.apache.hadoop.hbase.client.ClientServiceCallable<T>

org.apache.hadoop.hbase.client.NoncedRegionServerCallable<T>

Type Parameters:

T - the class that the ServerCallable handles

All Implemented Interfaces:

RetryingCallable<T>

@InterfaceAudience.Private
public abstract class NoncedRegionServerCallable<T>
extends ClientServiceCallable<T>

Implementations make an rpc call against a RegionService via a protobuf Service. Implement #rpcCall(RpcController) and then call RegionServerCallable.call(int) to trigger the rpc. The RegionServerCallable.call(int) eventually invokes your #rpcCall(RpcController) meanwhile saving you having to write a bunch of boilerplate. The RegionServerCallable.call(int) implementation is from RpcRetryingCaller so rpcs are retried on fail.

TODO: this class is actually tied to one region, because most of the paths make use of the regioninfo part of location when building requests. The only reason it works for multi-region requests (e.g. batch) is that they happen to not use the region parts. This could be done cleaner (e.g. having a generic parameter and 2 derived classes, RegionCallable and actual RegionServerCallable with ServerName.

Field Summary

Fields

Modifier and Type	Field and Description
private long	nonce

Fields inherited from class org.apache.hadoop.hbase.client.RegionServerCallable

location, rpcController, stub

Constructor Summary

Constructors

Constructor and Description
NoncedRegionServerCallable(Connection connection, TableName tableName, byte[] row, HBaseRpcController rpcController, int priority)

Method Summary

Modifier and Type	Method and Description
(package private) long	getNonce()
(package private) long	getNonceGroup()

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

doGet, doMutate, setStubByServiceName

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

call, getConnection, getExceptionMessageAdditionalDetail, getHRegionInfo, getLocation, getPriority, getRow, getRpcController, getRpcControllerCellScanner, getStub, getTableName, prepare, rpcCall, setLocation, setRpcControllerCellScanner, setStub, sleep, throwable

Methods inherited from class java.lang.Object

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

Field Detail

nonce

private final long nonce

Constructor Detail

NoncedRegionServerCallable

public NoncedRegionServerCallable(Connection connection,
                                  TableName tableName,
                                  byte[] row,
                                  HBaseRpcController rpcController,
                                  int priority)

Parameters:

connection - Connection to use.

tableName - Table name to which row belongs.

row - The row we want in tableName.

Method Detail

getNonceGroup

long getNonceGroup()

getNonce

long getNonce()