Uses of Class
org.apache.hadoop.hbase.client.AsyncProcessTask
Packages that use AsyncProcessTask
-
Uses of AsyncProcessTask in org.apache.hadoop.hbase.client
Methods in org.apache.hadoop.hbase.client that return AsyncProcessTaskModifier and TypeMethodDescriptionAsyncProcessTask.Builder.build()private AsyncProcessTaskBufferedMutatorImpl.createTask(BufferedMutatorImpl.QueueRowAccess access) Methods in org.apache.hadoop.hbase.client with parameters of type AsyncProcessTaskModifier and TypeMethodDescriptionprivate <CResult> AsyncRequestFutureAsyncProcess.checkTask(AsyncProcessTask<CResult> task) (package private) <CResult> AsyncRequestFutureImpl<CResult>AsyncProcess.createAsyncRequestFuture(AsyncProcessTask task, List<Action> actions, long nonceGroup) <CResult> AsyncRequestFutureAsyncProcess.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> AsyncRequestFutureAsyncProcess.submit(AsyncProcessTask<CResult> task, boolean atLeastOne) Extract from the rows list what we can submit.private <CResult> AsyncRequestFutureAsyncProcess.submitAll(AsyncProcessTask task) Submit immediately the list of rows, whatever the server status.(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 AsyncProcessTaskModifierConstructorDescription(package private)AsyncProcessTask(AsyncProcessTask<T> task) AsyncRequestFutureImpl(AsyncProcessTask task, List<Action> actions, long nonceGroup, AsyncProcess asyncProcess)