@InterfaceAudience.Private public class ClientSimpleScanner extends ClientScanner
cache, caching, callable, caller, closed, conf, currentRegion, lastNext, lastResult, maxScannerResultSize, pool, primaryOperationTimeout, rpcControllerFactory, scan, scanMetricsPublished, scannerTimeoutscanMetrics| Constructor and Description |
|---|
ClientSimpleScanner(org.apache.hadoop.conf.Configuration configuration,
Scan scan,
TableName name,
ClusterConnection connection,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
ExecutorService pool,
int replicaCallTimeoutMicroSecondScan) |
| Modifier and Type | Method and Description |
|---|---|
protected ScannerCallable |
createScannerCallable()
Will be called in moveToNextRegion to create ScannerCallable.
|
protected boolean |
setNewStartKey()
Will be called in moveToNextRegion when currentRegion is null.
|
close, getCacheSize, getCaching, getConf, getConnection, getMaxResultSize, getPool, getPrimaryOperationTimeout, getRetries, getScan, getScannerTimeout, getTable, getTableName, getTimestamp, loadCache, moveToNextRegion, next, renewLease, writeScanMetricsgetScanMetrics, initScanMetrics, iterator, nextpublic ClientSimpleScanner(org.apache.hadoop.conf.Configuration configuration,
Scan scan,
TableName name,
ClusterConnection connection,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
ExecutorService pool,
int replicaCallTimeoutMicroSecondScan)
throws IOException
IOExceptionprotected boolean setNewStartKey()
ClientScannersetNewStartKey in class ClientScannerfalse if we have reached the stop row. Otherwise true.protected ScannerCallable createScannerCallable()
ClientScannercreateScannerCallable in class ClientScannerCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.