Package 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
    Description
    (package private) AtomicInteger
    count
     
    (package private) final 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, memstoreOnlyReads, mixedReads, 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
    Description
    CellGridStoreScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.ExtendedCell
    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.ExtendedCell cell)
     
    protected boolean
    trySkipToNextRow(org.apache.hadoop.hbase.ExtendedCell cell)
     

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

    checkFlushed, checkScanOrder, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getReadPoint, 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, recordBlockSize, 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.InternalScanner

    next

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

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

  • Field Details

  • Constructor Details

  • Method Details

    • 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.ExtendedCell cell) throws IOException
      Overrides:
      trySkipToNextRow in class org.apache.hadoop.hbase.regionserver.StoreScanner
      Throws:
      IOException

    • trySkipToNextColumn

      protected boolean trySkipToNextColumn(org.apache.hadoop.hbase.ExtendedCell cell) throws IOException
      Overrides:
      trySkipToNextColumn in class org.apache.hadoop.hbase.regionserver.StoreScanner
      Throws:
      IOException

    • getNextIndexedKey

      public org.apache.hadoop.hbase.ExtendedCell getNextIndexedKey()
      Specified by:
      getNextIndexedKey in interface org.apache.hadoop.hbase.regionserver.KeyValueScanner
      Overrides:
      getNextIndexedKey in class org.apache.hadoop.hbase.regionserver.StoreScanner