Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Field and Description |
---|---|
private IdentityHashMap<Action,List<RetriesExhaustedException.ThrowableWithExtraContext>> |
AsyncBatchRpcRetryingCaller.action2Errors |
private IdentityHashMap<Action,CompletableFuture<T>> |
AsyncBatchRpcRetryingCaller.action2Future |
private List<Action> |
AsyncBatchRpcRetryingCaller.actions |
ConcurrentLinkedQueue<Action> |
AsyncBatchRpcRetryingCaller.RegionRequest.actions |
Modifier and Type | Method and Description |
---|---|
void |
AsyncBatchRpcRetryingCaller.ServerRequest.addAction(HRegionLocation loc,
Action action) |
private void |
AsyncBatchRpcRetryingCaller.addError(Action action,
Throwable error,
ServerName serverName) |
int |
Action.compareTo(Action other) |
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) |
private List<RetriesExhaustedException.ThrowableWithExtraContext> |
AsyncBatchRpcRetryingCaller.removeErrors(Action action) |
Modifier and Type | Method and Description |
---|---|
private void |
AsyncBatchRpcRetryingCaller.addError(Iterable<Action> actions,
Throwable error,
ServerName serverName) |
private void |
AsyncBatchRpcRetryingCaller.failAll(Stream<Action> actions,
int tries) |
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) |
Constructor and Description |
---|
Action(Action action,
int replicaId)
Creates an action for a particular replica from original action.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.