| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.client | Provides HBase Client | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ReversedScannerCallableA reversed ScannerCallable which supports backward scanning. | 
| Modifier and Type | Field and Description | 
|---|---|
| (package private) ScannerCallable | ScannerCallableWithReplicas.RetryingRPC. callable | 
| (package private) ScannerCallable | ScannerCallableWithReplicas. currentScannerCallable | 
| Modifier and Type | Field and Description | 
|---|---|
| private Set<ScannerCallable> | ScannerCallableWithReplicas. outstandingCallables | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ScannerCallable | ClientSimpleScanner. createScannerCallable() | 
| protected abstract ScannerCallable | ClientScanner. createScannerCallable()Will be called in moveToNextRegion to create ScannerCallable. | 
| ScannerCallable | ScannerCallable. getScannerCallableForReplica(int id) | 
| ScannerCallable | ReversedScannerCallable. getScannerCallableForReplica(int id) | 
| Modifier and Type | Method and Description | 
|---|---|
| Pair<Result[],ScannerCallable> | ScannerCallableWithReplicas.RetryingRPC. call(int callTimeout) | 
| Modifier and Type | Method and Description | 
|---|---|
| private void | ScannerCallableWithReplicas. setStartRowForReplicaCallable(ScannerCallable callable)Set the start row for the replica callable based on the state of the last result received. | 
| private void | ScannerCallableWithReplicas. updateCurrentlyServingReplica(ScannerCallable scanner,
                             Result[] result,
                             AtomicBoolean done,
                             ExecutorService pool) | 
| Modifier and Type | Method and Description | 
|---|---|
| private void | ScannerCallableWithReplicas. addCallsForCurrentReplica(ResultBoundedCompletionService<Pair<Result[],ScannerCallable>> cs) | 
| private void | ScannerCallableWithReplicas. addCallsForOtherReplicas(ResultBoundedCompletionService<Pair<Result[],ScannerCallable>> cs,
                        int min,
                        int max) | 
| Constructor and Description | 
|---|
| RetryingRPC(ScannerCallable callable) | 
| 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–2021 The Apache Software Foundation. All rights reserved.