org.apache.hadoop.hbase.regionserver

Class TestStoreScanner.CellGridStoreScanner

java.lang.Object

org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.StoreScanner

org.apache.hadoop.hbase.regionserver.TestStoreScanner.CellGridStoreScanner

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.ChangedReadersObserver, org.apache.hadoop.hbase.regionserver.InternalScanner, org.apache.hadoop.hbase.regionserver.KeyValueScanner, org.apache.hadoop.hbase.regionserver.Shipper

Enclosing class:

TestStoreScanner

private static class TestStoreScanner.CellGridStoreScanner
extends org.apache.hadoop.hbase.regionserver.StoreScanner

A StoreScanner for our CELL_GRID above. Fakes the block transitions. Does counts of calls to optimize and counts of when optimize actually did an optimize.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) AtomicInteger	count
(package private) AtomicInteger	optimization

Fields inherited from class org.apache.hadoop.hbase.regionserver.StoreScanner

currentScanners, DEFAULT_HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, heap, LAZY_SEEK_ENABLED_BY_DEFAULT, readPt, store, STORESCANNER_PARALLEL_SEEK_ENABLE, STORESCANNER_PREAD_MAX_BYTES

Fields inherited from interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

NO_NEXT_INDEXED_KEY

Constructor Summary

Constructors

Constructor and Description
CellGridStoreScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.Cell	getNextIndexedKey()
protected org.apache.hadoop.hbase.regionserver.KeyValueHeap	newKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.CellComparator comparator)
protected void	resetKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.CellComparator comparator)
protected boolean	trySkipToNextColumn(org.apache.hadoop.hbase.Cell cell)
protected boolean	trySkipToNextRow(org.apache.hadoop.hbase.Cell cell)

Methods inherited from class org.apache.hadoop.hbase.regionserver.StoreScanner

checkFlushed, checkScanOrder, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getReadPoint, getScannerOrder, isScanUsePread, next, next, peek, reopenAfterFlush, reseek, seek, seekAsDirection, seekScanners, seekToNextRow, selectScannersFrom, shipped, trySwitchToStreamRead, updateReaders

Methods inherited from class org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner

backwardSeek, seekToLastRow, seekToPreviousRow

Methods inherited from class org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner

doRealSeek, enforceSeek, getFilePath, isFileScanner, realSeekDone, requestSeek, shouldUseScanner

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

backwardSeek, enforceSeek, getFilePath, isFileScanner, realSeekDone, requestSeek, seekToLastRow, seekToPreviousRow, shouldUseScanner

Methods inherited from interface org.apache.hadoop.hbase.regionserver.InternalScanner

next

Field Detail

count

AtomicInteger count

optimization

final AtomicInteger optimization

Constructor Detail

CellGridStoreScanner

CellGridStoreScanner(org.apache.hadoop.hbase.client.Scan scan,
                     org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo)
              throws IOException

Throws:

IOException

Method Detail

resetKVHeap

protected void resetKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
                           org.apache.hadoop.hbase.CellComparator comparator)
                    throws IOException

Overrides:

resetKVHeap in class org.apache.hadoop.hbase.regionserver.StoreScanner

Throws:

IOException

newKVHeap

protected org.apache.hadoop.hbase.regionserver.KeyValueHeap newKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
                                                                      org.apache.hadoop.hbase.CellComparator comparator)
                                                               throws IOException

Overrides:

newKVHeap in class org.apache.hadoop.hbase.regionserver.StoreScanner

Throws:

IOException

trySkipToNextRow

protected boolean trySkipToNextRow(org.apache.hadoop.hbase.Cell cell)
                            throws IOException

Overrides:

trySkipToNextRow in class org.apache.hadoop.hbase.regionserver.StoreScanner

Throws:

IOException

trySkipToNextColumn

protected boolean trySkipToNextColumn(org.apache.hadoop.hbase.Cell cell)
                               throws IOException

Overrides:

trySkipToNextColumn in class org.apache.hadoop.hbase.regionserver.StoreScanner

Throws:

IOException

getNextIndexedKey

public org.apache.hadoop.hbase.Cell getNextIndexedKey()

Specified by:

getNextIndexedKey in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

Overrides:

getNextIndexedKey in class org.apache.hadoop.hbase.regionserver.StoreScanner