Uses of Class
org.apache.hadoop.hbase.client.CancellableRegionServerCallable
-
Uses of CancellableRegionServerCallable in org.apache.hadoop.hbase.client
Modifier and TypeClassDescription(package private) class
Callable that handles themulti
method call going against a single regionserver; i.e.(package private) class
A RegionServerCallable that takes into account the replicas, i.e.Modifier and TypeFieldDescriptionprivate CancellableRegionServerCallable
AsyncProcessTask.Builder.callable
private final CancellableRegionServerCallable
AsyncProcessTask.callable
private final CancellableRegionServerCallable
AsyncRequestFutureImpl.currentCallable
Modifier and TypeFieldDescriptionprivate final Set<CancellableRegionServerCallable>
AsyncRequestFutureImpl.callsInProgress
private final Set<CancellableRegionServerCallable>
AsyncRequestFutureImpl.SingleServerRequestRunnable.callsInProgress
Modifier and TypeMethodDescription(package private) CancellableRegionServerCallable
AsyncProcessTask.getCallable()
Modifier and TypeMethodDescriptionprotected Set<CancellableRegionServerCallable>
AsyncRequestFutureImpl.getCallsInProgress()
Modifier and TypeMethodDescriptionprotected RpcRetryingCaller<AbstractResponse>
AsyncProcess.createCaller
(CancellableRegionServerCallable callable, int rpcTimeout) Create a caller.(package private) AsyncProcessTask.Builder<T>
AsyncProcessTask.Builder.setCallable
(CancellableRegionServerCallable callable) Modifier and TypeMethodDescription(package private) AsyncRequestFutureImpl<CResult>.SingleServerRequestRunnable
AsyncRequestFutureImpl.createSingleServerRequest
(MultiAction multiAction, int numAttempt, ServerName server, Set<CancellableRegionServerCallable> callsInProgress) ModifierConstructorDescription(package private)
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) ModifierConstructorDescription(package private)
SingleServerRequestRunnable
(MultiAction multiAction, int numAttempt, ServerName server, Set<CancellableRegionServerCallable> callsInProgress)