| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.client | Provides HBase Client | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | RpcRetryingCallerImpl<T>Runs an rpc'ing  RetryingCallable. | 
| Modifier and Type | Field and Description | 
|---|---|
| private RpcRetryingCaller<Result[]> | ScannerCallableWithReplicas. caller | 
| (package private) RpcRetryingCaller<Result[]> | ScannerCallableWithReplicas.RetryingRPC. caller | 
| protected RpcRetryingCaller<Result[]> | ClientScanner. caller | 
| private RpcRetryingCaller<T> | ResultBoundedCompletionService.QueueingFuture. retryingCaller | 
| Modifier and Type | Method and Description | 
|---|---|
| protected RpcRetryingCaller<AbstractResponse> | AsyncProcess. createCaller(CancellableRegionServerCallable callable,
            int rpcTimeout)Create a caller. | 
| <T> RpcRetryingCaller<T> | RpcRetryingCallerFactory. newCaller()Create a new RetryingCaller with configured rpc timeout. | 
| <T> RpcRetryingCaller<T> | RpcRetryingCallerFactory. newCaller(int rpcTimeout)Create a new RetryingCaller with specific rpc timeout. | 
| Modifier and Type | Method and Description | 
|---|---|
| private Result[] | ClientScanner. call(ScannerCallableWithReplicas callable,
    RpcRetryingCaller<Result[]> caller,
    int scannerTimeout,
    boolean updateCurrentRegion) | 
| Constructor and Description | 
|---|
| ScannerCallableWithReplicas(TableName tableName,
                           ClusterConnection cConnection,
                           ScannerCallable baseCallable,
                           ExecutorService pool,
                           int timeBeforeReplicas,
                           Scan scan,
                           int retries,
                           int scannerTimeout,
                           int caching,
                           org.apache.hadoop.conf.Configuration conf,
                           RpcRetryingCaller<Result[]> caller) | 
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.