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()
String	getOperationId()
org.apache.hadoop.hbase.client.RegionInfo	getRegionInfo()
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)
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

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

getOperationId

public String getOperationId()

Specified by:

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

resetFilters

protected final 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

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

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