Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyCompactingMemStore

java.lang.Object
org.apache.hadoop.hbase.regionserver.AbstractMemStore
org.apache.hadoop.hbase.regionserver.CompactingMemStore
org.apache.hadoop.hbase.regionserver.TestHStore.MyCompactingMemStore
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.MemStore
Enclosing class:
TestHStore
public static class TestHStore.MyCompactingMemStore 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 final CountDownLatch
    getScannerLatch
     
    private final CountDownLatch
    snapshotLatch
     
    private static final AtomicBoolean
    START_TEST
     

    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
    MyCompactingMemStore(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.CellComparatorImpl c, 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 List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
    createList(int capacity)
     
    protected void
    pushActiveToPipeline(org.apache.hadoop.hbase.regionserver.MutableSegment active, boolean checkEmpty)
     

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

    checkAndAddToActiveSize, createMemStoreCompactor, debug, flattenOneSegment, flushInMemory, flushInMemory, getFamilyName, getFlushableSize, getImmutableSegments, getIndexType, getInmemoryFlushSize, getNextRow, getScanners, getSegments, getSmallestReadPoint, getStore, hasImmutableSegments, heapSize, inMemoryCompaction, isMemStoreFlushingInMemory, isSloppy, keySize, postUpdate, preFlushSeqIDEstimation, preUpdate, 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

    • MyCompactingMemStore

      public MyCompactingMemStore(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.CellComparatorImpl c, 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

    • createList

      protected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> createList(int capacity)
      Overrides:
      createList in class org.apache.hadoop.hbase.regionserver.CompactingMemStore

    • pushActiveToPipeline

      protected void pushActiveToPipeline(org.apache.hadoop.hbase.regionserver.MutableSegment active, boolean checkEmpty)
      Overrides:
      pushActiveToPipeline in class org.apache.hadoop.hbase.regionserver.CompactingMemStore