Uses of Class
org.apache.hadoop.hbase.client.AsyncProcessTask
-
Uses of AsyncProcessTask in org.apache.hadoop.hbase.client
Modifier and TypeMethodDescriptionAsyncProcessTask.Builder.build()
private AsyncProcessTask
BufferedMutatorImpl.createTask
(BufferedMutatorImpl.QueueRowAccess access) Modifier and TypeMethodDescriptionprivate <CResult> AsyncRequestFuture
AsyncProcess.checkTask
(AsyncProcessTask<CResult> task) (package private) <CResult> AsyncRequestFutureImpl<CResult>
AsyncProcess.createAsyncRequestFuture
(AsyncProcessTask task, List<Action> actions, long nonceGroup) <CResult> AsyncRequestFuture
AsyncProcess.submit
(AsyncProcessTask<CResult> task) The submitted task may be not accomplished at all if there are too many running tasks or other limits.private <CResult> AsyncRequestFuture
AsyncProcess.submit
(AsyncProcessTask<CResult> task, boolean atLeastOne) Extract from the rows list what we can submit.private <CResult> AsyncRequestFuture
AsyncProcess.submitAll
(AsyncProcessTask task) Submit immediately the list of rows, whatever the server status.(package private) <CResult> AsyncRequestFuture
AsyncProcess.submitMultiActions
(AsyncProcessTask task, List<Action> retainedActions, long nonceGroup, List<Exception> locationErrors, List<Integer> locationErrorRows, Map<ServerName, MultiAction> actionsByServer) ModifierConstructorDescription(package private)
AsyncProcessTask
(AsyncProcessTask<T> task) AsyncRequestFutureImpl
(AsyncProcessTask task, List<Action> actions, long nonceGroup, AsyncProcess asyncProcess)