Package org.apache.hadoop.hbase.client
Class AsyncRpcRetryingCaller<T>
java.lang.Object
org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller<T>
- Direct Known Subclasses:
AsyncAdminRequestRetryingCaller
,AsyncMasterRequestRpcRetryingCaller
,AsyncRegionReplicationRetryingCaller
,AsyncServerRequestRpcRetryingCaller
,AsyncSingleRequestRpcRetryingCaller
-
Field Summary
Modifier and TypeFieldDescriptionprotected final AsyncConnectionImpl
protected final HBaseRpcController
private final List<RetriesExhaustedException.ThrowableWithExtraContext>
protected final CompletableFuture<T>
private static final org.slf4j.Logger
private final int
protected final long
private final HBaseServerExceptionPauseManager
private final int
private final org.apache.hbase.thirdparty.io.netty.util.Timer
private final long
private final int
private final long
private int
-
Constructor Summary
ConstructorDescriptionAsyncRpcRetryingCaller
(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String, byte[]> requestAttributes) -
Method Summary
Modifier and TypeMethodDescription(package private) CompletableFuture<T>
call()
protected final void
protected abstract void
doCall()
private long
protected final void
protected Throwable
preProcessError
(Throwable error) protected final long
protected final void
private void
tryScheduleRetry
(Throwable error)
-
Field Details
-
LOG
-
retryTimer
-
priority
-
startNs
-
tries
-
maxAttempts
-
startLogErrorsCnt
-
exceptions
-
rpcTimeoutNs
-
operationTimeoutNs
-
conn
-
future
-
controller
-
pauseManager
-
-
Constructor Details
-
AsyncRpcRetryingCaller
public AsyncRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String, byte[]> requestAttributes)
-
-
Method Details
-
elapsedMs
-
remainingTimeNs
-
completeExceptionally
-
resetCallTimeout
-
tryScheduleRetry
-
getTableName
-
preProcessError
-
onError
-
doCall
-
call
-