@InterfaceAudience.Private public class ClientSmallReversedScanner extends ReversedClientScanner
ReversedClientScanner
Modifier and Type | Class and Description |
---|---|
protected static class |
ClientSmallReversedScanner.SmallReversedScannerCallableFactory |
cache, caching, callable, caller, closed, conf, currentRegion, lastCellLoadedToCache, lastNext, lastResult, maxScannerResultSize, partialResults, partialResultsRow, pool, primaryOperationTimeout, rpcControllerFactory, scan, scanMetricsPublished, scannerTimeout
scanMetrics
Constructor and Description |
---|
ClientSmallReversedScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ReversibleClientScanner for the specified table.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the scanner and releases any resources it has allocated
|
protected void |
initializeScannerInConstruction() |
protected void |
loadCache()
Contact the servers to load more
Result s in the cache. |
Result |
next()
Grab the next row's worth of values.
|
protected void |
setScannerCallableFactory(ClientSmallReversedScanner.SmallReversedScannerCallableFactory callableFactory) |
checkScanStopRow, getScannerCallable, nextScanner
createClosestRowBefore, getCacheSize, getCaching, getConf, getConnection, getMaxResultSize, getPool, getPrimaryOperationTimeout, getResultsToAddToCache, getRetries, getScan, getScannerCallable, getScannerTimeout, getTable, getTableName, getTimestamp, renewLease, updateLastCellLoadedToCache, writeScanMetrics
getScanMetrics, initScanMetrics, iterator, next
public ClientSmallReversedScanner(Configuration conf, Scan scan, TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, java.util.concurrent.ExecutorService pool, int primaryOperationTimeout) throws java.io.IOException
Scan
's start row maybe changed changed.conf
- The Configuration
to use.scan
- Scan
to use in this scannertableName
- The table that we wish to rangeGetconnection
- Connection identifying the clusterrpcFactory
- Factory used to create the RpcRetryingCaller
controllerFactory
- Factory used to access RPC payloadspool
- Threadpool for RPC threadsprimaryOperationTimeout
- Call timeoutjava.io.IOException
- If the remote call failspublic Result next() throws java.io.IOException
ResultScanner
next
in interface ResultScanner
next
in class ClientScanner
java.io.IOException
- eprotected void loadCache() throws java.io.IOException
ClientScanner
Result
s in the cache.loadCache
in class ClientScanner
java.io.IOException
protected void initializeScannerInConstruction() throws java.io.IOException
initializeScannerInConstruction
in class ClientScanner
java.io.IOException
public void close()
ResultScanner
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface ResultScanner
close
in class ClientScanner
protected void setScannerCallableFactory(ClientSmallReversedScanner.SmallReversedScannerCallableFactory callableFactory)