| Package | Description |
|---|---|
| org.apache.hadoop.hbase.client |
Provides HBase Client
|
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
ClientSmallReversedScanner.SmallReversedScannerCallable
A reversed ScannerCallable which supports backward small scanning.
|
(package private) static class |
ClientSmallScanner.SmallScannerCallable |
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 |
|---|---|
ScannerCallable |
ClientSmallScanner.SmallScannerCallable.getScannerCallableForReplica(int id) |
ScannerCallable |
ClientSmallReversedScanner.SmallReversedScannerCallable.getScannerCallableForReplica(int id) |
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,
RegionLocations rl) |
private void |
ScannerCallableWithReplicas.addCallsForOtherReplicas(ResultBoundedCompletionService<Pair<Result[],ScannerCallable>> cs,
RegionLocations rl,
int min,
int max) |
| Constructor and Description |
|---|
ScannerCallableWithReplicas.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.