Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
MultiServerCallable
Callable that handles the
multi method call going against a single
regionserver; i.e. |
(package private) class |
RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable
A RegionServerCallable that takes into account the replicas, i.e.
|
Modifier and Type | Field and Description |
---|---|
private CancellableRegionServerCallable |
AsyncProcessTask.callable |
private CancellableRegionServerCallable |
AsyncProcessTask.Builder.callable |
private CancellableRegionServerCallable |
AsyncRequestFutureImpl.currentCallable |
Modifier and Type | Field and Description |
---|---|
private Set<CancellableRegionServerCallable> |
AsyncRequestFutureImpl.callsInProgress |
private Set<CancellableRegionServerCallable> |
AsyncRequestFutureImpl.SingleServerRequestRunnable.callsInProgress |
Modifier and Type | Method and Description |
---|---|
(package private) CancellableRegionServerCallable |
AsyncProcessTask.getCallable() |
Modifier and Type | Method and Description |
---|---|
protected Set<CancellableRegionServerCallable> |
AsyncRequestFutureImpl.getCallsInProgress() |
Modifier and Type | Method and Description |
---|---|
protected RpcRetryingCaller<AbstractResponse> |
AsyncProcess.createCaller(CancellableRegionServerCallable callable,
int rpcTimeout)
Create a caller.
|
(package private) AsyncProcessTask.Builder<T> |
AsyncProcessTask.Builder.setCallable(CancellableRegionServerCallable callable) |
Modifier and Type | Method and Description |
---|---|
(package private) AsyncRequestFutureImpl.SingleServerRequestRunnable |
AsyncRequestFutureImpl.createSingleServerRequest(MultiAction multiAction,
int numAttempt,
ServerName server,
Set<CancellableRegionServerCallable> callsInProgress) |
Constructor and 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) |
Constructor and Description |
---|
SingleServerRequestRunnable(MultiAction multiAction,
int numAttempt,
ServerName server,
Set<CancellableRegionServerCallable> callsInProgress) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.