org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatReversedRegionScanner

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestScannerHeartbeatMessages.HeartbeatReversedRegionScanner

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.ipc.RpcCallback, org.apache.hadoop.hbase.regionserver.InternalScanner, org.apache.hadoop.hbase.regionserver.RegionScanner, org.apache.hadoop.hbase.regionserver.Shipper

Enclosing class:

TestScannerHeartbeatMessages

private static class TestScannerHeartbeatMessages.HeartbeatReversedRegionScanner
extends Object

Custom ReversedRegionScanner that can be configured to sleep between retrievals of row Results and/or column family cells

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hbase.CellComparator	comparator
protected boolean	includeStopRow
protected org.apache.hadoop.hbase.Cell	joinedContinuationRow
(package private) org.apache.hadoop.hbase.regionserver.KeyValueHeap	joinedHeap
protected org.apache.hadoop.hbase.regionserver.HRegion	region
protected byte[]	stopRow
(package private) org.apache.hadoop.hbase.regionserver.KeyValueHeap	storeHeap

Constructor Summary

Constructors

Constructor and Description
HeartbeatReversedRegionScanner(org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners, org.apache.hadoop.hbase.regionserver.HRegion region)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getBatch()
long	getMaxResultSize()
long	getMvccReadPoint()
org.apache.hadoop.hbase.client.RegionInfo	getRegionInfo()
(package private) org.apache.hadoop.hbase.regionserver.KeyValueHeap	getStoreHeapForTesting()
protected void	incrementCountOfRowsFilteredMetric(org.apache.hadoop.hbase.regionserver.ScannerContext arg0)
protected void	incrementCountOfRowsScannedMetric(org.apache.hadoop.hbase.regionserver.ScannerContext arg0)
protected void	initializeKVHeap(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> joinedScanners, org.apache.hadoop.hbase.regionserver.HRegion region)
protected void	initializeScanners(org.apache.hadoop.hbase.client.Scan arg0, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> arg1)
boolean	isFilterDone()
boolean	next(List<org.apache.hadoop.hbase.Cell> arg0)
boolean	next(List<org.apache.hadoop.hbase.Cell> arg0, org.apache.hadoop.hbase.regionserver.ScannerContext arg1)
boolean	nextRaw(List<org.apache.hadoop.hbase.Cell> arg0)
boolean	nextRaw(List<org.apache.hadoop.hbase.Cell> outResults, org.apache.hadoop.hbase.regionserver.ScannerContext context)
protected boolean	nextRow(org.apache.hadoop.hbase.regionserver.ScannerContext arg0, org.apache.hadoop.hbase.Cell arg1)
boolean	reseek(byte[] arg0)
protected void	resetFilters()
void	run()
void	shipped()
protected boolean	shouldStop(org.apache.hadoop.hbase.Cell arg0)

Methods inherited from class java.lang.Object

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

Field Detail

storeHeap

org.apache.hadoop.hbase.regionserver.KeyValueHeap storeHeap

joinedHeap

org.apache.hadoop.hbase.regionserver.KeyValueHeap joinedHeap

joinedContinuationRow

protected org.apache.hadoop.hbase.Cell joinedContinuationRow

stopRow

protected final byte[] stopRow

includeStopRow

protected final boolean includeStopRow

region

protected final org.apache.hadoop.hbase.regionserver.HRegion region

comparator

protected final org.apache.hadoop.hbase.CellComparator comparator

Constructor Detail

HeartbeatReversedRegionScanner

HeartbeatReversedRegionScanner(org.apache.hadoop.hbase.client.Scan scan,
                               List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners,
                               org.apache.hadoop.hbase.regionserver.HRegion region)
                        throws IOException

Throws:

IOException

Method Detail

nextRaw

public boolean nextRaw(List<org.apache.hadoop.hbase.Cell> outResults,
                       org.apache.hadoop.hbase.regionserver.ScannerContext context)
                throws IOException

Specified by:

nextRaw in interface org.apache.hadoop.hbase.regionserver.RegionScanner

Throws:

IOException

initializeKVHeap

protected void initializeKVHeap(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
                                List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> joinedScanners,
                                org.apache.hadoop.hbase.regionserver.HRegion region)
                         throws IOException

Throws:

IOException

shouldStop

protected boolean shouldStop(org.apache.hadoop.hbase.Cell arg0)

nextRow

protected boolean nextRow(org.apache.hadoop.hbase.regionserver.ScannerContext arg0,
                          org.apache.hadoop.hbase.Cell arg1)
                   throws IOException

Throws:

IOException

getRegionInfo

public org.apache.hadoop.hbase.client.RegionInfo getRegionInfo()

Specified by:

getRegionInfo in interface org.apache.hadoop.hbase.regionserver.RegionScanner

initializeScanners

protected void initializeScanners(org.apache.hadoop.hbase.client.Scan arg0,
                                  List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> arg1)
                           throws IOException

Throws:

IOException

getMaxResultSize

public long getMaxResultSize()

Specified by:

getMaxResultSize in interface org.apache.hadoop.hbase.regionserver.RegionScanner

getMvccReadPoint

public long getMvccReadPoint()

Specified by:

getMvccReadPoint in interface org.apache.hadoop.hbase.regionserver.RegionScanner

getBatch

public int getBatch()

Specified by:

getBatch in interface org.apache.hadoop.hbase.regionserver.RegionScanner

resetFilters

protected void resetFilters()
                     throws IOException

Throws:

IOException

next

public boolean next(List<org.apache.hadoop.hbase.Cell> arg0)
             throws IOException

Specified by:

next in interface org.apache.hadoop.hbase.regionserver.InternalScanner

Throws:

IOException

next

public boolean next(List<org.apache.hadoop.hbase.Cell> arg0,
                    org.apache.hadoop.hbase.regionserver.ScannerContext arg1)
             throws IOException

Specified by:

next in interface org.apache.hadoop.hbase.regionserver.InternalScanner

Throws:

IOException

nextRaw

public boolean nextRaw(List<org.apache.hadoop.hbase.Cell> arg0)
                throws IOException

Specified by:

nextRaw in interface org.apache.hadoop.hbase.regionserver.RegionScanner

Throws:

IOException

isFilterDone

public boolean isFilterDone()
                     throws IOException

Specified by:

isFilterDone in interface org.apache.hadoop.hbase.regionserver.RegionScanner

Throws:

IOException

incrementCountOfRowsFilteredMetric

protected void incrementCountOfRowsFilteredMetric(org.apache.hadoop.hbase.regionserver.ScannerContext arg0)

incrementCountOfRowsScannedMetric

protected void incrementCountOfRowsScannedMetric(org.apache.hadoop.hbase.regionserver.ScannerContext arg0)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.hbase.regionserver.InternalScanner

getStoreHeapForTesting

org.apache.hadoop.hbase.regionserver.KeyValueHeap getStoreHeapForTesting()

reseek

public boolean reseek(byte[] arg0)
               throws IOException

Specified by:

reseek in interface org.apache.hadoop.hbase.regionserver.RegionScanner

Throws:

IOException

shipped

public void shipped()
             throws IOException

Specified by:

shipped in interface org.apache.hadoop.hbase.regionserver.Shipper

Throws:

IOException

run

public void run()
         throws IOException

Specified by:

run in interface org.apache.hadoop.hbase.ipc.RpcCallback

Throws:

IOException