org.apache.hadoop.hbase.client

Class AsyncProcessTask<T>

java.lang.Object

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

Type Parameters:

T - The type of response from server-side

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class AsyncProcessTask<T>
extends Object

Contains the attributes of a task which will be executed by AsyncProcess. The attributes will be validated by AsyncProcess. It's intended for advanced client applications.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncProcessTask.Builder<T>
(package private) static class	AsyncProcessTask.ListRowAccess<T>
static class	AsyncProcessTask.SubmittedRows The number of processed rows.

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

Constructor and Description
AsyncProcessTask(AsyncProcessTask<T> task)
AsyncProcessTask(ExecutorService pool, TableName tableName, RowAccess<? extends Row> rows, AsyncProcessTask.SubmittedRows size, Batch.Callback<T> callback, CancellableRegionServerCallable callable, boolean needResults, int rpcTimeout, int operationTimeout, Object[] results)

Method Summary

Modifier and Type	Method and Description
(package private) CancellableRegionServerCallable	getCallable()
Batch.Callback<T>	getCallback()
boolean	getNeedResults()
int	getOperationTimeout()
ExecutorService	getPool()
(package private) Object[]	getResults()
RowAccess<? extends Row>	getRowAccess()
int	getRpcTimeout()
AsyncProcessTask.SubmittedRows	getSubmittedRows()
TableName	getTableName()
static AsyncProcessTask.Builder	newBuilder()
static <T> AsyncProcessTask.Builder<T>	newBuilder(Batch.Callback<T> callback)

Methods inherited from class java.lang.Object

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

Field Detail

pool

private final ExecutorService pool

tableName

private final TableName tableName

rows

private final RowAccess<? extends Row> rows

submittedRows

private final AsyncProcessTask.SubmittedRows submittedRows

callback

private final Batch.Callback<T> callback

callable

private final CancellableRegionServerCallable callable

needResults

private final boolean needResults

rpcTimeout

private final int rpcTimeout

operationTimeout

private final int operationTimeout

results

private final Object[] results

Constructor Detail

AsyncProcessTask

AsyncProcessTask(AsyncProcessTask<T> task)

AsyncProcessTask

AsyncProcessTask(ExecutorService pool,
                 TableName tableName,
                 RowAccess<? extends Row> rows,
                 AsyncProcessTask.SubmittedRows size,
                 Batch.Callback<T> callback,
                 CancellableRegionServerCallable callable,
                 boolean needResults,
                 int rpcTimeout,
                 int operationTimeout,
                 Object[] results)

Method Detail

newBuilder

public static <T> AsyncProcessTask.Builder<T> newBuilder(Batch.Callback<T> callback)

newBuilder

public static AsyncProcessTask.Builder newBuilder()

getOperationTimeout

public int getOperationTimeout()

getPool

public ExecutorService getPool()

getTableName

public TableName getTableName()

getRowAccess

public RowAccess<? extends Row> getRowAccess()

getSubmittedRows

public AsyncProcessTask.SubmittedRows getSubmittedRows()

getCallback

public Batch.Callback<T> getCallback()

getCallable

CancellableRegionServerCallable getCallable()

getResults

Object[] getResults()

getNeedResults

public boolean getNeedResults()

getRpcTimeout

public int getRpcTimeout()