public static class AsyncProcessTask.Builder<T> extends Object
Modifier and Type | Field and Description |
---|---|
private CancellableRegionServerCallable |
callable |
private Batch.Callback<T> |
callback |
private boolean |
needResults |
private int |
operationTimeout |
private ExecutorService |
pool |
private Object[] |
results |
private RowAccess<? extends Row> |
rows |
private int |
rpcTimeout |
private AsyncProcessTask.SubmittedRows |
submittedRows |
private TableName |
tableName |
Modifier | Constructor and Description |
---|---|
private |
Builder() |
private |
Builder(Batch.Callback<T> callback) |
Modifier and Type | Method and Description |
---|---|
AsyncProcessTask<T> |
build() |
(package private) AsyncProcessTask.Builder<T> |
setCallable(CancellableRegionServerCallable callable) |
AsyncProcessTask.Builder<T> |
setNeedResults(boolean needResults) |
AsyncProcessTask.Builder<T> |
setOperationTimeout(int operationTimeout) |
AsyncProcessTask.Builder<T> |
setPool(ExecutorService pool) |
(package private) AsyncProcessTask.Builder<T> |
setResults(Object[] results) |
AsyncProcessTask.Builder<T> |
setRowAccess(List<? extends Row> rows) |
AsyncProcessTask.Builder<T> |
setRowAccess(RowAccess<? extends Row> rows) |
AsyncProcessTask.Builder<T> |
setRpcTimeout(int rpcTimeout) |
AsyncProcessTask.Builder<T> |
setSubmittedRows(AsyncProcessTask.SubmittedRows submittedRows) |
AsyncProcessTask.Builder<T> |
setTableName(TableName tableName) |
private ExecutorService pool
private AsyncProcessTask.SubmittedRows submittedRows
private Batch.Callback<T> callback
private boolean needResults
private int rpcTimeout
private int operationTimeout
private CancellableRegionServerCallable callable
private Builder()
private Builder(Batch.Callback<T> callback)
AsyncProcessTask.Builder<T> setResults(Object[] results)
public AsyncProcessTask.Builder<T> setPool(ExecutorService pool)
public AsyncProcessTask.Builder<T> setRpcTimeout(int rpcTimeout)
public AsyncProcessTask.Builder<T> setOperationTimeout(int operationTimeout)
public AsyncProcessTask.Builder<T> setTableName(TableName tableName)
public AsyncProcessTask.Builder<T> setRowAccess(List<? extends Row> rows)
public AsyncProcessTask.Builder<T> setRowAccess(RowAccess<? extends Row> rows)
public AsyncProcessTask.Builder<T> setSubmittedRows(AsyncProcessTask.SubmittedRows submittedRows)
public AsyncProcessTask.Builder<T> setNeedResults(boolean needResults)
AsyncProcessTask.Builder<T> setCallable(CancellableRegionServerCallable callable)
public AsyncProcessTask<T> build()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.