Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyCompactingMemStore2

java.lang.Object
org.apache.hadoop.hbase.regionserver.AbstractMemStore
org.apache.hadoop.hbase.regionserver.CompactingMemStore
org.apache.hadoop.hbase.regionserver.TestHStore.MyCompactingMemStore2
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.MemStore
Enclosing class:
TestHStore
public static class TestHStore.MyCompactingMemStore2 extends org.apache.hadoop.hbase.regionserver.CompactingMemStore

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.CompactingMemStore

    org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private static final String
    LARGE_CELL_THREAD_NAME
     
    private final AtomicInteger
    largeCellPreUpdateCounter
     
    private final CyclicBarrier
    postCyclicBarrier
     
    private final CyclicBarrier
    preCyclicBarrier
     
    private static final String
    SMALL_CELL_THREAD_NAME
     
    private final AtomicInteger
    smallCellPreUpdateCounter
     

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

    allowCompaction, COMPACTING_MEMSTORE_TYPE_DEFAULT, COMPACTING_MEMSTORE_TYPE_KEY, compactor, DEEP_OVERHEAD, IN_MEMORY_CONPACTION_POOL_SIZE_DEFAULT, IN_MEMORY_CONPACTION_POOL_SIZE_KEY, IN_MEMORY_FLUSH_THRESHOLD_FACTOR_KEY

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

    FIXED_OVERHEAD, regionServices, snapshot, snapshotId

  • Constructor Summary

    Constructors
    Constructor
    Description
    MyCompactingMemStore2(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.CellComparatorImpl cellComparator, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.RegionServicesForStores regionServices, org.apache.hadoop.hbase.MemoryCompactionPolicy compactionPolicy)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    checkAndAddToActiveSize(org.apache.hadoop.hbase.regionserver.MutableSegment currActive, org.apache.hadoop.hbase.Cell cellToAdd, org.apache.hadoop.hbase.regionserver.MemStoreSizing memstoreSizing)
     
    protected void
    doAdd(org.apache.hadoop.hbase.regionserver.MutableSegment currentActive, org.apache.hadoop.hbase.ExtendedCell cell, org.apache.hadoop.hbase.regionserver.MemStoreSizing memstoreSizing)
     
    protected void
    flushInMemory(org.apache.hadoop.hbase.regionserver.MutableSegment currentActiveMutableSegment)
     

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

    createList, createMemStoreCompactor, debug, flattenOneSegment, flushInMemory, getFamilyName, getFlushableSize, getImmutableSegments, getIndexType, getInmemoryFlushSize, getNextRow, getScanners, getSegments, getSmallestReadPoint, getStore, hasImmutableSegments, heapSize, inMemoryCompaction, isMemStoreFlushingInMemory, isSloppy, keySize, postUpdate, preFlushSeqIDEstimation, preUpdate, pushActiveToPipeline, setCompositeSnapshot, setIndexType, setInMemoryCompactionCompleted, setInMemoryCompactionFlag, size, sizeAddedPreOperation, snapshot, startReplayingFromWAL, stopReplayingFromWAL, swapCompactedSegments, swapPipelineWithNull, updateLowestUnflushedSequenceIdInWAL

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

    add, add, addToScanners, addToScanners, clearSnapshot, close, doClearSnapShot, dump, getActive, getComparator, getConfiguration, getLowest, getNextRow, getSnapshot, getSnapshotSize, resetActive, resetTimeOfOldestEdit, timeOfOldestEdit, toString, upsert

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • MyCompactingMemStore2

      public MyCompactingMemStore2(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.CellComparatorImpl cellComparator, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.RegionServicesForStores regionServices, org.apache.hadoop.hbase.MemoryCompactionPolicy compactionPolicy) throws IOException
      Throws:
      IOException

  • Method Details

    • checkAndAddToActiveSize

      protected boolean checkAndAddToActiveSize(org.apache.hadoop.hbase.regionserver.MutableSegment currActive, org.apache.hadoop.hbase.Cell cellToAdd, org.apache.hadoop.hbase.regionserver.MemStoreSizing memstoreSizing)
      Overrides:
      checkAndAddToActiveSize in class org.apache.hadoop.hbase.regionserver.CompactingMemStore

    • doAdd

      protected void doAdd(org.apache.hadoop.hbase.regionserver.MutableSegment currentActive, org.apache.hadoop.hbase.ExtendedCell cell, org.apache.hadoop.hbase.regionserver.MemStoreSizing memstoreSizing)
      Overrides:
      doAdd in class org.apache.hadoop.hbase.regionserver.AbstractMemStore

    • flushInMemory

      protected void flushInMemory(org.apache.hadoop.hbase.regionserver.MutableSegment currentActiveMutableSegment)
      Overrides:
      flushInMemory in class org.apache.hadoop.hbase.regionserver.CompactingMemStore