| Package | Description |
|---|---|
| org.apache.hadoop.hbase.client |
Provides HBase Client
|
| Modifier and Type | Field and Description |
|---|---|
Map<byte[],List<Action<R>>> |
MultiAction.actions |
private List<Action<Row>> |
AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable.initialActions |
| Modifier and Type | Method and Description |
|---|---|
void |
MultiAction.add(byte[] regionName,
Action<R> a)
Add an Action to this container based on it's regionName.
|
private static void |
AsyncProcess.addAction(ServerName server,
byte[] regionName,
Action<Row> action,
Map<ServerName,MultiAction<Row>> actionsByServer,
long nonceGroup)
Helper that is used when grouping the actions per region server.
|
private void |
AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable.addReplicaActionsAgain(Action<Row> action,
Map<ServerName,MultiAction<Row>> actionsByServer) |
private RegionLocations |
AsyncProcess.AsyncRequestFutureImpl.findAllLocationsOrFail(Action<Row> action,
boolean useCache) |
private HRegionLocation |
AsyncProcess.AsyncRequestFutureImpl.getReplicaLocationOrFail(Action<Row> action) |
private void |
AsyncProcess.AsyncRequestFutureImpl.manageLocationError(Action<Row> action,
Exception ex) |
private static void |
AsyncProcess.setNonce(NonceGenerator ng,
Row r,
Action<Row> action) |
private void |
AsyncProcess.AsyncRequestFutureImpl.setResult(Action<Row> action,
Object result)
Sets the non-error result from a particular action.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MultiAction.add(byte[] regionName,
List<Action<R>> actionList)
Add an Action to this container based on it's regionName.
|
void |
DelayingRunner.add(Map.Entry<byte[],List<Action<T>>> e) |
private void |
AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable.addReplicaActions(int index,
Map<ServerName,MultiAction<Row>> actionsByServer,
List<Action<Row>> unknownReplicaActions)
Add replica actions to action map by server.
|
protected <CResult> AsyncProcess.AsyncRequestFutureImpl<CResult> |
AsyncProcess.createAsyncRequestFuture(TableName tableName,
List<Action<Row>> actions,
long nonceGroup,
ExecutorService pool,
Batch.Callback<CResult> callback,
Object[] results,
boolean needResults) |
private void |
AsyncProcess.AsyncRequestFutureImpl.groupAndSendMultiAction(List<Action<Row>> currentActions,
int numAttempt)
Group a list of actions per region servers, and send them.
|
private void |
AsyncProcess.AsyncRequestFutureImpl.resubmit(ServerName oldServer,
List<Action<Row>> toReplay,
int numAttempt,
int failureCount,
Throwable throwable)
Log as much info as possible, and, if there is something to replay,
submit it again after a back off sleep.
|
private void |
AsyncProcess.AsyncRequestFutureImpl.sendMultiAction(Map<ServerName,MultiAction<Row>> actionsByServer,
int numAttempt,
List<Action<Row>> actionsForReplicaThread,
boolean reuseThread)
Send a multi action structure to the servers, after a delay depending on the attempt
number.
|
private void |
AsyncProcess.AsyncRequestFutureImpl.startWaitingForReplicaCalls(List<Action<Row>> actionsForReplicaThread)
Starts waiting to issue replica calls on a different thread; or issues them immediately.
|
(package private) <CResult> AsyncProcess.AsyncRequestFuture |
AsyncProcess.submitMultiActions(TableName tableName,
List<Action<Row>> retainedActions,
long nonceGroup,
Batch.Callback<CResult> callback,
Object[] results,
boolean needResults,
List<Exception> locationErrors,
List<Integer> locationErrorRows,
Map<ServerName,MultiAction<Row>> actionsByServer,
ExecutorService pool) |
| Constructor and Description |
|---|
Action(Action<R> action,
int replicaId)
Creates an action for a particular replica from original action.
|
| Constructor and Description |
|---|
AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable(List<Action<Row>> initialActions,
long startTime) |
AsyncProcess.AsyncRequestFutureImpl(TableName tableName,
List<Action<Row>> actions,
long nonceGroup,
ExecutorService pool,
boolean needResults,
Object[] results,
Batch.Callback<CResult> callback) |
DelayingRunner(long sleepTime,
Map.Entry<byte[],List<Action<T>>> e) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.