Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyCompactingMemStore3

java.lang.Object
org.apache.hadoop.hbase.regionserver.AbstractMemStore
org.apache.hadoop.hbase.regionserver.CompactingMemStore
org.apache.hadoop.hbase.regionserver.TestHStore.MyCompactingMemStore3
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.MemStore
Enclosing class:
TestHStore
public static class TestHStore.MyCompactingMemStore3 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 int
    CELL_COUNT
     
    private boolean
    flushByteSizeLessThanSmallAndLargeCellSize
     
    private final AtomicInteger
    flushCounter
     
    private static final String
    LARGE_CELL_THREAD_NAME
     
    private final CyclicBarrier
    postCyclicBarrier
     
    private final CyclicBarrier
    preCyclicBarrier
     
    private static final String
    SMALL_CELL_THREAD_NAME
     

    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
    MyCompactingMemStore3(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)
     
    (package private) void
    disableCompaction()
     
    (package private) void
    enableCompaction()
     
    protected void
    flushInMemory(org.apache.hadoop.hbase.regionserver.MutableSegment currentActiveMutableSegment)
     
    protected void
    postUpdate(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, 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, doAdd, 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

    • MyCompactingMemStore3

      public MyCompactingMemStore3(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

    • postUpdate

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

    • flushInMemory

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

    • disableCompaction

      void disableCompaction()

    • enableCompaction

      void enableCompaction()