Uses of Class
org.apache.hadoop.hbase.client.ScannerCallable
-
Uses of ScannerCallable in org.apache.hadoop.hbase.client
Modifier and TypeClassDescriptionclass
A reversed ScannerCallable which supports backward scanning.Modifier and TypeFieldDescription(package private) final ScannerCallable
ScannerCallableWithReplicas.RetryingRPC.callable
(package private) ScannerCallable
ScannerCallableWithReplicas.currentScannerCallable
Modifier and TypeFieldDescriptionprivate Set<ScannerCallable>
ScannerCallableWithReplicas.outstandingCallables
Modifier and TypeMethodDescriptionprotected abstract ScannerCallable
ClientScanner.createScannerCallable()
Will be called in moveToNextRegion to create ScannerCallable.protected ScannerCallable
ClientSimpleScanner.createScannerCallable()
ReversedScannerCallable.getScannerCallableForReplica
(int id) ScannerCallable.getScannerCallableForReplica
(int id) Modifier and TypeMethodDescriptionprivate 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 TypeMethodDescriptionprivate void
ScannerCallableWithReplicas.addCallsForCurrentReplica
(ResultBoundedCompletionService<Pair<Result[], ScannerCallable>> cs, int rpcTimeout) private void
ScannerCallableWithReplicas.addCallsForOtherReplicas
(ResultBoundedCompletionService<Pair<Result[], ScannerCallable>> cs, int min, int max, int rpcTimeout) ModifierConstructorDescription(package private)
RetryingRPC
(ScannerCallable callable) ScannerCallableWithReplicas
(TableName tableName, ClusterConnection cConnection, ScannerCallable baseCallable, ExecutorService pool, int timeBeforeReplicas, Scan scan, int retries, int readRpcTimeout, int scannerTimeout, boolean useScannerTimeoutForNextCalls, int caching, org.apache.hadoop.conf.Configuration conf, RpcRetryingCaller<Result[]> caller)