org.apache.hadoop.hbase.regionserver

Class ReversedRegionScannerImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl

org.apache.hadoop.hbase.regionserver.ReversedRegionScannerImpl

All Implemented Interfaces:

Closeable, AutoCloseable, RpcCallback, InternalScanner, RegionScanner, Shipper

@InterfaceAudience.Private
class ReversedRegionScannerImpl
extends HRegion.RegionScannerImpl

ReversibleRegionScannerImpl extends from RegionScannerImpl, and is used to support reversed scanning.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl

comparator, includeStopRow, joinedContinuationRow, joinedHeap, region, stopRow, storeHeap

Constructor Summary

Constructors

Constructor and Description
ReversedRegionScannerImpl(Scan scan, List<KeyValueScanner> additionalScanners, HRegion region)

Method Summary

Modifier and Type	Method and Description
protected void	initializeKVHeap(List<KeyValueScanner> scanners, List<KeyValueScanner> joinedScanners, HRegion region)
protected boolean	nextRow(ScannerContext scannerContext, Cell curRowCell)
protected boolean	shouldStop(Cell currentRowCell)

Methods inherited from class org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl

close, getBatch, getMaxResultSize, getMvccReadPoint, getRegionInfo, getStoreHeapForTesting, incrementCountOfRowsFilteredMetric, incrementCountOfRowsScannedMetric, initializeScanners, isFilterDone, next, next, nextRaw, nextRaw, reseek, resetFilters, run, shipped

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReversedRegionScannerImpl

ReversedRegionScannerImpl(Scan scan,
                          List<KeyValueScanner> additionalScanners,
                          HRegion region)
                   throws IOException

Parameters:

scan -

additionalScanners -

region -

Throws:

IOException

Method Detail

initializeKVHeap

protected void initializeKVHeap(List<KeyValueScanner> scanners,
                                List<KeyValueScanner> joinedScanners,
                                HRegion region)
                         throws IOException

Overrides:

initializeKVHeap in class HRegion.RegionScannerImpl

Throws:

IOException

shouldStop

protected boolean shouldStop(Cell currentRowCell)

Overrides:

shouldStop in class HRegion.RegionScannerImpl

nextRow

protected boolean nextRow(ScannerContext scannerContext,
                          Cell curRowCell)
                   throws IOException

Overrides:

nextRow in class HRegion.RegionScannerImpl

Throws:

IOException