Package 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

@Private
@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	Description
static class	AsyncProcessTask.Builder<T>
(package private) static class	AsyncProcessTask.ListRowAccess<T>
static enum	AsyncProcessTask.SubmittedRows	The number of processed rows.

Field Summary

Fields

Modifier and Type	Field	Description
private final CancellableRegionServerCallable	callable
private final Batch.Callback<T>	callback
private final boolean	needResults
private final int	operationTimeout
private final ExecutorService	pool
private final Map<String,byte[]>	requestAttributes
private final Object[]	results
private final RowAccess<? extends Row>	rows
private final int	rpcTimeout
private final AsyncProcessTask.SubmittedRows	submittedRows
private final TableName	tableName

Constructor Summary

Constructors

Constructor	Description
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, Map<String,byte[]> requestAttributes)
AsyncProcessTask(AsyncProcessTask<T> task)

Method Summary

Modifier and Type	Method	Description
(package private) CancellableRegionServerCallable	getCallable()
Batch.Callback<T>	getCallback()
boolean	getNeedResults()
int	getOperationTimeout()
ExecutorService	getPool()
Map<String,byte[]>	getRequestAttributes()
(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 Details

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

requestAttributes

private final Map<String,byte[]> requestAttributes

Constructor Details

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,
 Map<String,byte[]> requestAttributes)

Method Details

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()

getRequestAttributes

public Map<String,byte[]> getRequestAttributes()

getResults

Object[] getResults()

getNeedResults

public boolean getNeedResults()

getRpcTimeout

public int getRpcTimeout()