Package org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatKVHeap

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.TestScannerHeartbeatMessages.HeartbeatKVHeap
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.HeartbeatKVHeap extends org.apache.hadoop.hbase.regionserver.KeyValueHeap
Custom KV Heap that can be configured to sleep/wait in between retrievals of column family cells. Useful for testing

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

    close, getCurrentForTesting, getHeap, getNextIndexedKey, isLatestCellFromMemstore, next, peek, pollRealKV, recordBlockSize, 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

  • Constructor Details

    • HeartbeatKVHeap

      public HeartbeatKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.CellComparator comparator) throws IOException
      Throws:
      IOException

    • HeartbeatKVHeap

      HeartbeatKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.regionserver.KeyValueHeap.KVScannerComparator comparator) throws IOException
      Throws:
      IOException

  • 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