Uses of Class
org.apache.hadoop.hbase.client.Action
-
Uses of Action in org.apache.hadoop.hbase.client
Modifier and TypeFieldDescriptionprivate final IdentityHashMap<Action,
List<RetriesExhaustedException.ThrowableWithExtraContext>> AsyncBatchRpcRetryingCaller.action2Errors
private final IdentityHashMap<Action,
CompletableFuture<T>> AsyncBatchRpcRetryingCaller.action2Future
AsyncBatchRpcRetryingCaller.actions
final ConcurrentLinkedQueue<Action>
AsyncBatchRpcRetryingCaller.RegionRequest.actions
Modifier and TypeMethodDescriptionvoid
AsyncBatchRpcRetryingCaller.ServerRequest.addAction
(HRegionLocation loc, Action action) private void
AsyncBatchRpcRetryingCaller.addError
(Action action, Throwable error, ServerName serverName) int
private void
AsyncBatchRpcRetryingCaller.failOne
(Action action, int tries, Throwable error, long currentTime, String extras) private void
AsyncBatchRpcRetryingCaller.onComplete
(Action action, AsyncBatchRpcRetryingCaller.RegionRequest regionReq, int tries, ServerName serverName, MultiResponse.RegionResult regionResult, List<Action> failedActions, Throwable regionException, org.apache.commons.lang3.mutable.MutableBoolean retryImmediately) AsyncBatchRpcRetryingCaller.removeErrors
(Action action) Modifier and TypeMethodDescriptionprivate void
AsyncBatchRpcRetryingCaller.addError
(Iterable<Action> actions, Throwable error, ServerName serverName) private void
private void
AsyncBatchRpcRetryingCaller.failAll
(Stream<Action> actions, int tries, Throwable error, ServerName serverName) private void
AsyncBatchRpcRetryingCaller.groupAndSend
(Stream<Action> actions, int tries) private void
AsyncBatchRpcRetryingCaller.onComplete
(Action action, AsyncBatchRpcRetryingCaller.RegionRequest regionReq, int tries, ServerName serverName, MultiResponse.RegionResult regionResult, List<Action> failedActions, Throwable regionException, org.apache.commons.lang3.mutable.MutableBoolean retryImmediately) private void
AsyncBatchRpcRetryingCaller.tryResubmit
(Stream<Action> actions, int tries, boolean immediately, Throwable error)