| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.client | 
 Provides HBase Client 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ReversedScannerCallable
A 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–2020 The Apache Software Foundation. All rights reserved.