Package 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	Description
private CancellableRegionServerCallable	callable
private Batch.Callback<T>	callback
private boolean	needResults
private int	operationTimeout
private ExecutorService	pool
private Map<String,byte[]>	requestAttributes
private Object[]	results
private RowAccess<? extends Row>	rows
private int	rpcTimeout
private AsyncProcessTask.SubmittedRows	submittedRows
private TableName	tableName

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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>	setRequestAttributes(Map<String,byte[]> requestAttributes)
(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 Details

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

requestAttributes

private Map<String,byte[]> requestAttributes

Constructor Details

Builder

private Builder()

Builder

private Builder(Batch.Callback<T> callback)

Method Details

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)

setRequestAttributes

AsyncProcessTask.Builder<T> setRequestAttributes(Map<String,byte[]> requestAttributes)

build

public AsyncProcessTask<T> build()