Package org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatReversedRegionScanner

java.lang.Object
org.apache.hadoop.hbase.regionserver.RegionScannerImpl
org.apache.hadoop.hbase.regionserver.TestScannerHeartbeatMessages.HeartbeatReversedRegionScanner
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.ipc.RpcCallback, org.apache.hadoop.hbase.regionserver.InternalScanner, org.apache.hadoop.hbase.regionserver.RegionScanner, org.apache.hadoop.hbase.regionserver.Shipper
Enclosing class:
TestScannerHeartbeatMessages
private static class TestScannerHeartbeatMessages.HeartbeatReversedRegionScanner extends org.apache.hadoop.hbase.regionserver.RegionScannerImpl
Custom ReversedRegionScanner that can be configured to sleep between retrievals of row Results and/or column family cells

  • Field Summary

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

    comparator, includeStopRow, joinedContinuationRow, joinedHeap, region, stopRow, storeHeap

  • Constructor Summary

    Constructors
    Constructor
    Description
    HeartbeatReversedRegionScanner(org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners, org.apache.hadoop.hbase.regionserver.HRegion region)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    initializeKVHeap(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> joinedScanners, org.apache.hadoop.hbase.regionserver.HRegion region)
     
    boolean
    nextRaw(List<? super org.apache.hadoop.hbase.ExtendedCell> outResults, org.apache.hadoop.hbase.regionserver.ScannerContext context)
     
    protected boolean
    nextRow(org.apache.hadoop.hbase.regionserver.ScannerContext arg0, org.apache.hadoop.hbase.Cell arg1)
     
    protected boolean
    shouldStop(org.apache.hadoop.hbase.Cell arg0)
     

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

    close, getBatch, getContext, getMaxResultSize, getMvccReadPoint, getOperationId, getRegionInfo, isFilterDone, next, next, nextRaw, reseek, resetFilters, run, shipped

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • nextRaw

      public boolean nextRaw(List<? super org.apache.hadoop.hbase.ExtendedCell> outResults, org.apache.hadoop.hbase.regionserver.ScannerContext context) throws IOException
      Specified by:
      nextRaw in interface org.apache.hadoop.hbase.regionserver.RegionScanner
      Overrides:
      nextRaw in class org.apache.hadoop.hbase.regionserver.RegionScannerImpl
      Throws:
      IOException

    • initializeKVHeap

      protected void initializeKVHeap(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> joinedScanners, org.apache.hadoop.hbase.regionserver.HRegion region) throws IOException
      Throws:
      IOException

    • shouldStop

      protected boolean shouldStop(org.apache.hadoop.hbase.Cell arg0)
      Overrides:
      shouldStop in class org.apache.hadoop.hbase.regionserver.RegionScannerImpl

    • nextRow

      protected boolean nextRow(org.apache.hadoop.hbase.regionserver.ScannerContext arg0, org.apache.hadoop.hbase.Cell arg1) throws IOException
      Overrides:
      nextRow in class org.apache.hadoop.hbase.regionserver.RegionScannerImpl
      Throws:
      IOException