Package 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>
Retry caller for a single request, such as get, put, delete, etc.
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic interface
-
Field Summary
Modifier and TypeFieldDescriptionprivate final AsyncSingleRequestRpcRetryingCaller.Callable<T>
private final RegionLocateType
private final int
private final byte[]
private final TableName
Fields inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller
conn, controller, future, operationTimeoutNs
-
Constructor Summary
ConstructorDescriptionAsyncSingleRequestRpcRetryingCaller
(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 pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String, byte[]> requestAttributes) -
Method Summary
Methods inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller
call, completeExceptionally, onError, preProcessError, remainingTimeNs, resetCallTimeout
-
Field Details
-
tableName
-
row
-
replicaId
-
locateType
-
callable
-
-
Constructor Details
-
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 pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String, byte[]> requestAttributes)
-
-
Method Details
-
call
-
doCall
- Specified by:
doCall
in classAsyncRpcRetryingCaller<T>
-
getTableName
- Overrides:
getTableName
in classAsyncRpcRetryingCaller<T>
-