org.apache.hadoop.hbase.client

Class AsyncProcessTask.Builder<T>

java.lang.Object

org.apache.hadoop.hbase.client.AsyncProcessTask.Builder<T>

Enclosing class:

AsyncProcessTask<T>

public static class AsyncProcessTask.Builder<T>
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Builder()
private	Builder(Batch.Callback<T> callback)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pool

private ExecutorService pool

tableName

private TableName tableName

rows

private RowAccess<? extends Row> rows

submittedRows

private AsyncProcessTask.SubmittedRows submittedRows

callback

private Batch.Callback<T> callback

needResults

private boolean needResults

rpcTimeout

private int rpcTimeout

operationTimeout

private int operationTimeout

callable

private CancellableRegionServerCallable callable

results

private Object[] results

Constructor Detail

Builder

private Builder()

Builder

private Builder(Batch.Callback<T> callback)

Method Detail

setResults

AsyncProcessTask.Builder<T> setResults(Object[] results)

setPool

public AsyncProcessTask.Builder<T> setPool(ExecutorService pool)

setRpcTimeout

public AsyncProcessTask.Builder<T> setRpcTimeout(int rpcTimeout)

setOperationTimeout

public AsyncProcessTask.Builder<T> setOperationTimeout(int operationTimeout)

setTableName

public AsyncProcessTask.Builder<T> setTableName(TableName tableName)

setRowAccess

public AsyncProcessTask.Builder<T> setRowAccess(List<? extends Row> rows)

setRowAccess

public AsyncProcessTask.Builder<T> setRowAccess(RowAccess<? extends Row> rows)

setSubmittedRows

public AsyncProcessTask.Builder<T> setSubmittedRows(AsyncProcessTask.SubmittedRows submittedRows)

setNeedResults

public AsyncProcessTask.Builder<T> setNeedResults(boolean needResults)

setCallable

AsyncProcessTask.Builder<T> setCallable(CancellableRegionServerCallable callable)

build

public AsyncProcessTask<T> build()