| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.client | 
 Provides HBase Client 
 | 
| org.apache.hadoop.hbase.replication.regionserver | 
| Modifier and Type | Class and Description | 
|---|---|
(package private) class  | 
CancellableRegionServerCallable<T>
This class is used to unify HTable calls with AsyncProcess Framework. 
 | 
class  | 
ClientServiceCallable<T>
A RegionServerCallable set to use the Client protocol. 
 | 
class  | 
FlushRegionCallable
A Callable for flushRegion() RPC. 
 | 
(package private) class  | 
MasterCallable<V>
A RetryingCallable for Master RPC operations. 
 | 
(package private) class  | 
MultiServerCallable
Callable that handles the  
multi method call going against a single
 regionserver; i.e. | 
class  | 
NoncedRegionServerCallable<T>
Implementations make an rpc call against a RegionService via a protobuf Service. 
 | 
class  | 
RegionAdminServiceCallable<T>
Similar to RegionServerCallable but for the AdminService interface. 
 | 
class  | 
RegionServerCallable<T,S>
Implementations make a RPC call against a RegionService via a protobuf Service. 
 | 
class  | 
ReversedScannerCallable
A reversed ScannerCallable which supports backward scanning. 
 | 
(package private) class  | 
RpcRetryingCallable<V>
A RetryingCallable for RPC connection operations. 
 | 
(package private) class  | 
RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable
A RegionServerCallable that takes into account the replicas, i.e. 
 | 
class  | 
ScannerCallable
Scanner operations such as create, next, etc. 
 | 
(package private) class  | 
ScannerCallableWithReplicas
This class has the logic for handling scanners for regions with and without replicas. 
 | 
(package private) class  | 
ScannerCallableWithReplicas.RetryingRPC  | 
| Modifier and Type | Field and Description | 
|---|---|
private RetryingCallable<T> | 
ResultBoundedCompletionService.QueueingFuture.future  | 
| Modifier and Type | Method and Description | 
|---|---|
private <C extends RetryingCallable<V> & Closeable,V> | 
HBaseAdmin.executeCallable(C callable)  | 
private static <C extends RetryingCallable<V> & Closeable,V> | 
HBaseAdmin.executeCallable(C callable,
               RpcRetryingCallerFactory rpcCallerFactory,
               int operationTimeout,
               int rpcTimeout)  | 
| Modifier and Type | Method and Description | 
|---|---|
T | 
RpcRetryingCallerImpl.callWithoutRetries(RetryingCallable<T> callable,
                  int callTimeout)  | 
T | 
RpcRetryingCaller.callWithoutRetries(RetryingCallable<T> callable,
                  int callTimeout)
Call the server once only. 
 | 
T | 
RpcRetryingCallerImpl.callWithRetries(RetryingCallable<T> callable,
               int callTimeout)  | 
T | 
RpcRetryingCaller.callWithRetries(RetryingCallable<T> callable,
               int callTimeout)
Retries if invocation fails. 
 | 
abstract RetryingCallerInterceptorContext | 
RetryingCallerInterceptorContext.prepare(RetryingCallable<?> callable)
This prepares the context object by populating it with information specific
 to the implementation of the  
RetryingCallerInterceptor along with
 which this will be used. | 
FastFailInterceptorContext | 
FastFailInterceptorContext.prepare(RetryingCallable<?> callable)  | 
RetryingCallerInterceptorContext | 
NoOpRetryingInterceptorContext.prepare(RetryingCallable<?> callable)  | 
abstract RetryingCallerInterceptorContext | 
RetryingCallerInterceptorContext.prepare(RetryingCallable<?> callable,
       int tries)
Telescopic extension that takes which of the many retries we are currently
 in. 
 | 
FastFailInterceptorContext | 
FastFailInterceptorContext.prepare(RetryingCallable<?> callable,
       int tries)  | 
RetryingCallerInterceptorContext | 
NoOpRetryingInterceptorContext.prepare(RetryingCallable<?> callable,
       int tries)  | 
void | 
ResultBoundedCompletionService.submit(RetryingCallable<V> task,
      int callTimeout,
      int id)  | 
| Constructor and Description | 
|---|
QueueingFuture(RetryingCallable<T> future,
              int callTimeout,
              int id)  | 
| Modifier and Type | Class and Description | 
|---|---|
(package private) static class  | 
RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable
Calls replay on the passed edits for the given set of entries belonging to the region. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
(package private) RetryingCallable<V> | 
RegionReplicaReplicationEndpoint.RetryingRpcCallable.callable  | 
| Constructor and Description | 
|---|
RetryingRpcCallable(RpcRetryingCallerFactory factory,
                   RetryingCallable<V> callable,
                   int timeout)  | 
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.