Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyKeyValueHeap

java.lang.Object

org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.KeyValueHeap

org.apache.hadoop.hbase.regionserver.TestHStore.MyKeyValueHeap

All Implemented Interfaces:

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

Enclosing class:

TestHStore

private static class TestHStore.MyKeyValueHeap
extends org.apache.hadoop.hbase.regionserver.KeyValueHeap

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.KeyValueHeap

org.apache.hadoop.hbase.regionserver.KeyValueHeap.KVScannerComparator

Field Summary

Fields

Modifier and Type	Field	Description
private final TestHStore.MyKeyValueHeapHook	hook
private int	recordBlockSizeCallCount

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

comparator, current, heap, scannersForDelayedClose

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

NO_NEXT_INDEXED_KEY

Constructor Summary

Constructors

Constructor	Description
MyKeyValueHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.CellComparator comparator, TestHStore.MyKeyValueHeapHook hook)

Method Summary

Modifier and Type	Method	Description
void	recordBlockSize(IntConsumer blockSizeConsumer)

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

close, getCurrentForTesting, getHeap, getNextIndexedKey, isLatestCellFromMemstore, next, next, peek, pollRealKV, requestSeek, reseek, seek, shipped

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, 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.InternalScanner

next

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

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

Field Details

hook

private final TestHStore.MyKeyValueHeapHook hook

recordBlockSizeCallCount

private int recordBlockSizeCallCount

Constructor Details

MyKeyValueHeap

public MyKeyValueHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
 org.apache.hadoop.hbase.CellComparator comparator,
 TestHStore.MyKeyValueHeapHook hook)
               throws IOException

Throws:

IOException

Method Details

recordBlockSize

public void recordBlockSize(IntConsumer blockSizeConsumer)

Specified by:

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

Overrides:

recordBlockSize in class org.apache.hadoop.hbase.regionserver.KeyValueHeap