Uses of Class
org.apache.hadoop.hbase.client.MultiAction
Packages that use MultiAction
-
Uses of MultiAction in org.apache.hadoop.hbase.client
Fields in org.apache.hadoop.hbase.client declared as MultiActionModifier and TypeFieldDescriptionprivate MultiActionDelayingRunner.actionsprivate final MultiActionAsyncRequestFutureImpl.SingleServerRequestRunnable.multiActionprivate MultiActionMultiServerCallable.multiActionMethods in org.apache.hadoop.hbase.client that return MultiActionModifier and TypeMethodDescriptionDelayingRunner.getActions()(package private) MultiActionMultiServerCallable.getMulti()Methods in org.apache.hadoop.hbase.client with parameters of type MultiActionModifier and TypeMethodDescriptionprivate MultiServerCallableAsyncRequestFutureImpl.createCallable(ServerName server, TableName tableName, MultiAction multi) Create a callable.(package private) AsyncRequestFutureImpl<CResult>.SingleServerRequestRunnableAsyncRequestFutureImpl.createSingleServerRequest(MultiAction multiAction, int numAttempt, ServerName server, Set<CancellableRegionServerCallable> callsInProgress) private voidAsyncRequestFutureImpl.failAll(MultiAction actions, ServerName server, int numAttempt, Throwable throwable) Fail all the actions from this multiaction after an OperationTimeoutExceededExceptionprivate Collection<? extends Runnable>AsyncRequestFutureImpl.getNewMultiActionRunnable(ServerName server, MultiAction multiAction, int numAttempt) private voidAsyncRequestFutureImpl.receiveGlobalFailure(MultiAction rsActions, ServerName server, int numAttempt, Throwable t, boolean clearServerCache) Resubmit all the actions from this multiaction after a failure.private voidAsyncRequestFutureImpl.receiveMultiAction(MultiAction multiAction, ServerName server, MultiResponse responses, int numAttempt) Called when we receive the result of a server query.voidMultiServerCallable.reset(ServerName location, MultiAction multiAction) Method parameters in org.apache.hadoop.hbase.client with type arguments of type MultiActionModifier and TypeMethodDescription(package private) static voidAsyncProcess.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 voidAsyncRequestFutureImpl.ReplicaCallIssuingRunnable.addReplicaActions(int index, Map<ServerName, MultiAction> actionsByServer, List<Action> unknownReplicaActions) Add replica actions to action map by server.private voidAsyncRequestFutureImpl.ReplicaCallIssuingRunnable.addReplicaActionsAgain(Action action, Map<ServerName, MultiAction> actionsByServer) (package private) voidAsyncRequestFutureImpl.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> AsyncRequestFutureAsyncProcess.submitMultiActions(AsyncProcessTask task, List<Action> retainedActions, long nonceGroup, List<Exception> locationErrors, List<Integer> locationErrorRows, Map<ServerName, MultiAction> actionsByServer) Constructors in org.apache.hadoop.hbase.client with parameters of type MultiActionModifierConstructorDescription(package private)MultiServerCallable(ClusterConnection connection, TableName tableName, ServerName location, MultiAction multi, org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController, int rpcTimeout, RetryingTimeTracker tracker, int priority, Map<String, byte[]> requestAttributes) (package private)SingleServerRequestRunnable(MultiAction multiAction, int numAttempt, ServerName server, Set<CancellableRegionServerCallable> callsInProgress)