Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Method and Description |
---|---|
AsyncProcessTask<T> |
AsyncProcessTask.Builder.build() |
private AsyncProcessTask |
BufferedMutatorImpl.createTask(BufferedMutatorImpl.QueueRowAccess access) |
Modifier and Type | Method and Description |
---|---|
private <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) |
Constructor and Description |
---|
AsyncProcessTask(AsyncProcessTask<T> task) |
AsyncRequestFutureImpl(AsyncProcessTask task,
List<Action> actions,
long nonceGroup,
AsyncProcess asyncProcess) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.