| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.client | 
 Provides HBase Client 
 | 
| Modifier and Type | Field and Description | 
|---|---|
private MultiAction | 
DelayingRunner.actions  | 
private MultiAction | 
AsyncRequestFutureImpl.SingleServerRequestRunnable.multiAction  | 
private MultiAction | 
MultiServerCallable.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–2020 The Apache Software Foundation. All rights reserved.