Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Field and Description |
---|---|
private MultiAction |
DelayingRunner.actions |
private MultiAction |
MultiServerCallable.multiAction |
private MultiAction |
AsyncRequestFutureImpl.SingleServerRequestRunnable.multiAction |
Modifier and Type | Method and Description |
---|---|
MultiAction |
DelayingRunner.getActions() |
(package private) MultiAction |
MultiServerCallable.getMulti() |
Modifier and Type | Method and Description |
---|---|
private MultiServerCallable |
AsyncRequestFutureImpl.createCallable(ServerName server,
TableName tableName,
MultiAction multi)
Create a callable.
|
(package private) AsyncRequestFutureImpl.SingleServerRequestRunnable |
AsyncRequestFutureImpl.createSingleServerRequest(MultiAction multiAction,
int numAttempt,
ServerName server,
Set<CancellableRegionServerCallable> callsInProgress) |
private Collection<? extends Runnable> |
AsyncRequestFutureImpl.getNewMultiActionRunnable(ServerName server,
MultiAction multiAction,
int numAttempt) |
private void |
AsyncRequestFutureImpl.receiveGlobalFailure(MultiAction rsActions,
ServerName server,
int numAttempt,
Throwable t)
Resubmit all the actions from this multiaction after a failure.
|
private void |
AsyncRequestFutureImpl.receiveMultiAction(MultiAction multiAction,
ServerName server,
MultiResponse responses,
int numAttempt)
Called when we receive the result of a server query.
|
void |
MultiServerCallable.reset(ServerName location,
MultiAction multiAction) |
Modifier and Type | Method and Description |
---|---|
(package private) static void |
AsyncProcess.addAction(ServerName server,
byte[] regionName,
Action action,
Map<ServerName,MultiAction> actionsByServer,
long nonceGroup)
Helper that is used when grouping the actions per region server.
|
private void |
AsyncRequestFutureImpl.ReplicaCallIssuingRunnable.addReplicaActions(int index,
Map<ServerName,MultiAction> actionsByServer,
List<Action> unknownReplicaActions)
Add replica actions to action map by server.
|
private void |
AsyncRequestFutureImpl.ReplicaCallIssuingRunnable.addReplicaActionsAgain(Action action,
Map<ServerName,MultiAction> actionsByServer) |
(package private) void |
AsyncRequestFutureImpl.sendMultiAction(Map<ServerName,MultiAction> actionsByServer,
int numAttempt,
List<Action> actionsForReplicaThread,
boolean reuseThread)
Send a multi action structure to the servers, after a delay depending on the attempt
number.
|
(package private) <CResult> AsyncRequestFuture |
AsyncProcess.submitMultiActions(AsyncProcessTask task,
List<Action> retainedActions,
long nonceGroup,
List<Exception> locationErrors,
List<Integer> locationErrorRows,
Map<ServerName,MultiAction> actionsByServer) |
Constructor and Description |
---|
MultiServerCallable(ClusterConnection connection,
TableName tableName,
ServerName location,
MultiAction multi,
org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController,
int rpcTimeout,
RetryingTimeTracker tracker,
int priority) |
SingleServerRequestRunnable(MultiAction multiAction,
int numAttempt,
ServerName server,
Set<CancellableRegionServerCallable> callsInProgress) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.