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