@InterfaceAudience.Private public class ReversedClientScanner extends ClientScanner
| Modifier and Type | Field and Description |
|---|---|
private static org.apache.commons.logging.Log |
LOG |
cache, caching, callable, caller, closed, conf, currentRegion, lastCellLoadedToCache, lastNext, lastResult, MAX_BYTE_ARRAY, maxScannerResultSize, partialResults, partialResultsRow, 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 boolean |
checkScanStopRow(byte[] startKey) |
protected ScannerCallableWithReplicas |
getScannerCallable(byte[] localStartKey,
int nbRows,
byte[] locateStartRow) |
protected boolean |
nextScanner(int nbRows,
boolean done) |
call, close, createClosestRowBefore, getCacheSize, getCaching, getConf, getConnection, getMaxResultSize, getPool, getPrimaryOperationTimeout, getResultsToAddToCache, getRetries, getScan, getScannerCallable, getScannerTimeout, getTable, getTableName, getTimestamp, initializeScannerInConstruction, isAnyRPCcancelled, loadCache, next, renewLease, updateLastCellLoadedToCache, 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 nextScanner(int nbRows,
boolean done)
throws IOException
nextScanner in class ClientScannerIOExceptionprotected ScannerCallableWithReplicas getScannerCallable(byte[] localStartKey, int nbRows, byte[] locateStartRow)
protected boolean checkScanStopRow(byte[] startKey)
checkScanStopRow in class ClientScannerCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.