Package org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatReversedKVHeap

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.ReversedKeyValueHeap
org.apache.hadoop.hbase.regionserver.TestScannerHeartbeatMessages.HeartbeatReversedKVHeap
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:
TestScannerHeartbeatMessages
private static final class TestScannerHeartbeatMessages.HeartbeatReversedKVHeap extends org.apache.hadoop.hbase.regionserver.ReversedKeyValueHeap
Custom reversed KV Heap that can be configured to sleep in between retrievals of column family cells.

  • 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 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
    HeartbeatReversedKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.CellComparatorImpl comparator)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    next(List<? super org.apache.hadoop.hbase.ExtendedCell> result, org.apache.hadoop.hbase.regionserver.ScannerContext context)
     

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

    backwardSeek, next, requestSeek, reseek, seek, seekToLastRow, seekToPreviousRow

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

    close, getCurrentForTesting, getHeap, getNextIndexedKey, isLatestCellFromMemstore, peek, pollRealKV, recordBlockSize, shipped

    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

    enforceSeek, getFilePath, getScannerOrder, isFileScanner, realSeekDone, shouldUseScanner

  • Constructor Details

  • Method Details

    • next

      public boolean next(List<? super org.apache.hadoop.hbase.ExtendedCell> result, org.apache.hadoop.hbase.regionserver.ScannerContext context) throws IOException
      Specified by:
      next in interface org.apache.hadoop.hbase.regionserver.InternalScanner
      Overrides:
      next in class org.apache.hadoop.hbase.regionserver.KeyValueHeap
      Throws:
      IOException