Package org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatRegionScanner

java.lang.Object
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 Object
Custom RegionScanner that can be configured to sleep between retrievals of row Results and/or column family cells

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final org.apache.hadoop.hbase.CellComparator
    comparator
     
    protected final boolean
    includeStopRow
     
    protected org.apache.hadoop.hbase.Cell
    joinedContinuationRow
     
    (package private) org.apache.hadoop.hbase.regionserver.KeyValueHeap
    joinedHeap
     
    protected final org.apache.hadoop.hbase.regionserver.HRegion
    region
     
    protected final byte[]
    stopRow
     
    (package private) org.apache.hadoop.hbase.regionserver.KeyValueHeap
    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
    void
    close()
     
    int
    getBatch()
     
    long
    getMaxResultSize()
     
    long
    getMvccReadPoint()
     
    String
    getOperationId()
     
    org.apache.hadoop.hbase.client.RegionInfo
    getRegionInfo()
     
    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
    isFilterDone()
     
    boolean
    next(List<org.apache.hadoop.hbase.Cell> arg0)
     
    boolean
    next(List<org.apache.hadoop.hbase.Cell> arg0, org.apache.hadoop.hbase.regionserver.ScannerContext arg1)
     
    boolean
    nextRaw(List<org.apache.hadoop.hbase.Cell> arg0)
     
    boolean
    nextRaw(List<org.apache.hadoop.hbase.Cell> outResults, org.apache.hadoop.hbase.regionserver.ScannerContext context)
     
    protected boolean
    nextRow(org.apache.hadoop.hbase.regionserver.ScannerContext arg0, org.apache.hadoop.hbase.Cell arg1)
     
    boolean
    reseek(byte[] arg0)
     
    protected final void
    resetFilters()
     
    void
    run()
     
    void
    shipped()
     
    protected boolean
    shouldStop(org.apache.hadoop.hbase.Cell arg0)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • storeHeap

      org.apache.hadoop.hbase.regionserver.KeyValueHeap storeHeap

    • joinedHeap

      org.apache.hadoop.hbase.regionserver.KeyValueHeap joinedHeap

    • joinedContinuationRow

      protected org.apache.hadoop.hbase.Cell joinedContinuationRow

    • stopRow

      protected final byte[] stopRow

    • includeStopRow

      protected final boolean includeStopRow

    • region

      protected final org.apache.hadoop.hbase.regionserver.HRegion region

    • comparator

      protected final org.apache.hadoop.hbase.CellComparator comparator

  • 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<org.apache.hadoop.hbase.Cell> outResults, org.apache.hadoop.hbase.regionserver.ScannerContext context) throws IOException
      Specified by:
      nextRaw in interface org.apache.hadoop.hbase.regionserver.RegionScanner
      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

    • getRegionInfo

      public org.apache.hadoop.hbase.client.RegionInfo getRegionInfo()
      Specified by:
      getRegionInfo in interface org.apache.hadoop.hbase.regionserver.RegionScanner

    • getMaxResultSize

      public long getMaxResultSize()
      Specified by:
      getMaxResultSize in interface org.apache.hadoop.hbase.regionserver.RegionScanner

    • getMvccReadPoint

      public long getMvccReadPoint()
      Specified by:
      getMvccReadPoint in interface org.apache.hadoop.hbase.regionserver.RegionScanner

    • getBatch

      public int getBatch()
      Specified by:
      getBatch in interface org.apache.hadoop.hbase.regionserver.RegionScanner

    • getOperationId

      public String getOperationId()
      Specified by:
      getOperationId in interface org.apache.hadoop.hbase.regionserver.RegionScanner

    • resetFilters

      protected final void resetFilters() throws IOException
      Throws:
      IOException

    • next

      public boolean next(List<org.apache.hadoop.hbase.Cell> arg0) throws IOException
      Specified by:
      next in interface org.apache.hadoop.hbase.regionserver.InternalScanner
      Throws:
      IOException

    • next

      public boolean next(List<org.apache.hadoop.hbase.Cell> arg0, org.apache.hadoop.hbase.regionserver.ScannerContext arg1) throws IOException
      Specified by:
      next in interface org.apache.hadoop.hbase.regionserver.InternalScanner
      Throws:
      IOException

    • nextRaw

      public boolean nextRaw(List<org.apache.hadoop.hbase.Cell> arg0) throws IOException
      Specified by:
      nextRaw in interface org.apache.hadoop.hbase.regionserver.RegionScanner
      Throws:
      IOException

    • isFilterDone

      public boolean isFilterDone() throws IOException
      Specified by:
      isFilterDone in interface org.apache.hadoop.hbase.regionserver.RegionScanner
      Throws:
      IOException

    • nextRow

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

    • shouldStop

      protected boolean shouldStop(org.apache.hadoop.hbase.Cell arg0)

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.hadoop.hbase.regionserver.InternalScanner

    • reseek

      public boolean reseek(byte[] arg0) throws IOException
      Specified by:
      reseek in interface org.apache.hadoop.hbase.regionserver.RegionScanner
      Throws:
      IOException

    • shipped

      public void shipped() throws IOException
      Specified by:
      shipped in interface org.apache.hadoop.hbase.regionserver.Shipper
      Throws:
      IOException

    • run

      public void run() throws IOException
      Specified by:
      run in interface org.apache.hadoop.hbase.ipc.RpcCallback
      Throws:
      IOException