@InterfaceAudience.Private public class ReversedClientScanner extends ClientScanner
cache, caching, callable, caller, closed, conf, currentRegion, lastNext, lastResult, maxScannerResultSize, pool, primaryOperationTimeout, rpcControllerFactory, scan, scanMetricsPublished, scannerTimeoutscanMetrics| Constructor and Description |
|---|
ReversedClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
ExecutorService pool,
int primaryOperationTimeout)
Create a new ReversibleClientScanner for the specified table Note that the passed
Scan's start row maybe changed. |
| Modifier and Type | Method and Description |
|---|---|
protected ReversedScannerCallable |
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 ReversedClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
ExecutorService pool,
int primaryOperationTimeout)
throws IOException
Scan's start row maybe changed.conf - scan - tableName - connection - pool - primaryOperationTimeout - IOExceptionprotected boolean setNewStartKey()
ClientScannersetNewStartKey in class ClientScannerfalse if we have reached the stop row. Otherwise true.protected ReversedScannerCallable createScannerCallable()
ClientScannercreateScannerCallable in class ClientScannerCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.