Package org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatRegionScanner

java.lang.Object
org.apache.hadoop.hbase.regionserver.RegionScannerImpl
org.apache.hadoop.hbase.regionserver.TestScannerHeartbeatMessages.HeartbeatRegionScanner
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.HeartbeatRegionScanner extends org.apache.hadoop.hbase.regionserver.RegionScannerImpl
Custom RegionScanner 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
    HeartbeatRegionScanner(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)
     

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

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

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • HeartbeatRegionScanner

      HeartbeatRegionScanner(org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners, org.apache.hadoop.hbase.regionserver.HRegion region) throws IOException
      Throws:
      IOException

  • 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
      Overrides:
      initializeKVHeap in class org.apache.hadoop.hbase.regionserver.RegionScannerImpl
      Throws:
      IOException