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

@Private
public abstract class AsyncRpcRetryingCaller<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final AsyncConnectionImpl	conn
protected final HBaseRpcController	controller
private final List<RetriesExhaustedException.ThrowableWithExtraContext>	exceptions
protected final CompletableFuture<T>	future
private static final org.slf4j.Logger	LOG
private final int	maxAttempts
protected final long	operationTimeoutNs
private final HBaseServerExceptionPauseManager	pauseManager
private final int	priority
private final org.apache.hbase.thirdparty.io.netty.util.Timer	retryTimer
private final long	rpcTimeoutNs
private final int	startLogErrorsCnt
private final long	startNs
private int	tries

Constructor Summary

Constructors

Constructor	Description
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 Summary

Modifier and Type	Method	Description
(package private) CompletableFuture<T>	call()
protected final void	completeExceptionally()
protected abstract void	doCall()
private long	elapsedMs()
protected Optional<TableName>	getTableName()
protected final void	onError(Throwable t, Supplier<String> errMsg, Consumer<Throwable> updateCachedLocation)
protected Throwable	preProcessError(Throwable error)
protected final long	remainingTimeNs()
protected final void	resetCallTimeout()
private void	tryScheduleRetry(Throwable error)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

retryTimer

private final org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer

priority

private final int priority

startNs

private final long startNs

tries

private int tries

maxAttempts

private final int maxAttempts

startLogErrorsCnt

private final int startLogErrorsCnt

exceptions

private final List<RetriesExhaustedException.ThrowableWithExtraContext> exceptions

rpcTimeoutNs

private final long rpcTimeoutNs

operationTimeoutNs

protected final long operationTimeoutNs

conn

protected final AsyncConnectionImpl conn

future

protected final CompletableFuture<T> future

controller

protected final HBaseRpcController controller

pauseManager

private final HBaseServerExceptionPauseManager 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

private long elapsedMs()

remainingTimeNs

protected final long remainingTimeNs()

completeExceptionally

protected final void completeExceptionally()

resetCallTimeout

protected final void resetCallTimeout()

tryScheduleRetry

private void tryScheduleRetry(Throwable error)

getTableName

protected Optional<TableName> getTableName()

preProcessError

protected Throwable preProcessError(Throwable error)

onError

protected final void onError(Throwable t,
 Supplier<String> errMsg,
 Consumer<Throwable> updateCachedLocation)

doCall

protected abstract void doCall()

call

CompletableFuture<T> call()