| 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–2020 The Apache Software Foundation. All rights reserved.