org.apache.hadoop.hbase.client

Class AsyncSingleRequestRpcRetryingCaller<T>

java.lang.Object

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

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

@InterfaceAudience.Private
class AsyncSingleRequestRpcRetryingCaller<T>
extends AsyncRpcRetryingCaller<T>

Retry caller for a single request, such as get, put, delete, etc.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AsyncSingleRequestRpcRetryingCaller.Callable<T>

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncSingleRequestRpcRetryingCaller.Callable<T>	callable
private RegionLocateType	locateType
private int	replicaId
private byte[]	row
private TableName	tableName

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

conn, controller, future, operationTimeoutNs

Constructor Summary

Constructors

Constructor and Description
AsyncSingleRequestRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, TableName tableName, byte[] row, int replicaId, RegionLocateType locateType, AsyncSingleRequestRpcRetryingCaller.Callable<T> callable, int priority, long pauseNs, long pauseForCQTBENs, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt)

Method Summary

Modifier and Type	Method and Description
private void	call(HRegionLocation loc)
protected void	doCall()
protected Optional<TableName>	getTableName()

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

call, completeExceptionally, onError, remainingTimeNs, resetCallTimeout

Methods inherited from class java.lang.Object

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

Field Detail

tableName

private final TableName tableName

row

private final byte[] row

replicaId

private final int replicaId

locateType

private final RegionLocateType locateType

callable

private final AsyncSingleRequestRpcRetryingCaller.Callable<T> callable

Constructor Detail

AsyncSingleRequestRpcRetryingCaller

public AsyncSingleRequestRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer,
                                           AsyncConnectionImpl conn,
                                           TableName tableName,
                                           byte[] row,
                                           int replicaId,
                                           RegionLocateType locateType,
                                           AsyncSingleRequestRpcRetryingCaller.Callable<T> callable,
                                           int priority,
                                           long pauseNs,
                                           long pauseForCQTBENs,
                                           int maxAttempts,
                                           long operationTimeoutNs,
                                           long rpcTimeoutNs,
                                           int startLogErrorsCnt)

Method Detail

call

private void call(HRegionLocation loc)

doCall

protected void doCall()

Specified by:

doCall in class AsyncRpcRetryingCaller<T>

getTableName

protected Optional<TableName> getTableName()

Overrides:

getTableName in class AsyncRpcRetryingCaller<T>