Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyCompactingMemStore4

java.lang.Object
org.apache.hadoop.hbase.regionserver.AbstractMemStore
org.apache.hadoop.hbase.regionserver.CompactingMemStore
org.apache.hadoop.hbase.regionserver.TestHStore.MyCompactingMemStore4
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.MemStore
Enclosing class:
TestHStore
public static class TestHStore.MyCompactingMemStore4 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 AtomicInteger
    flattenOneSegmentCounter
     
    private final CyclicBarrier
    flattenOneSegmentPostCyclicBarrier
    Only after CompactingMemStore.flattenOneSegment(long, org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action) completed, CompactingMemStore.swapPipelineWithNull(org.apache.hadoop.hbase.regionserver.VersionedSegmentsList) could execute.
    private final CyclicBarrier
    flattenOneSegmentPreCyclicBarrier
    CompactingMemStore.flattenOneSegment(long, org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action) must execute after CompactingMemStore.getImmutableSegments()
    private final AtomicInteger
    getImmutableSegmentsListCounter
     
    private final CyclicBarrier
    inMemoryCompactionEndCyclicBarrier
    To wait for CompactingMemStore.InMemoryCompactionRunnable stopping.
    private final AtomicInteger
    setInMemoryCompactionFlagCounter
     
    private final CyclicBarrier
    snapShotStartCyclicCyclicBarrier
    Only the in memory compact thread enters CompactingMemStore.flattenOneSegment(long, org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action),the snapshot thread starts CompactingMemStore.snapshot(),because CompactingMemStore.snapshot() would invoke CompactingMemStore.stopCompaction().
    private final AtomicInteger
    swapPipelineWithNullCounter
     
    private static final String
    TAKE_SNAPSHOT_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
    MyCompactingMemStore4(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
    void
    flattenOneSegment(long requesterVersion, org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action action)
     
    org.apache.hadoop.hbase.regionserver.VersionedSegmentsList
    getImmutableSegments()
     
    (package private) void
    inMemoryCompaction()
     
    protected boolean
    setInMemoryCompactionFlag()
     
    protected boolean
    swapPipelineWithNull(org.apache.hadoop.hbase.regionserver.VersionedSegmentsList segments)
     

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

    checkAndAddToActiveSize, createList, createMemStoreCompactor, debug, flushInMemory, flushInMemory, getFamilyName, getFlushableSize, getIndexType, getInmemoryFlushSize, getNextRow, getScanners, getSegments, getSmallestReadPoint, getStore, hasImmutableSegments, heapSize, isMemStoreFlushingInMemory, isSloppy, keySize, postUpdate, preFlushSeqIDEstimation, preUpdate, pushActiveToPipeline, setCompositeSnapshot, setIndexType, setInMemoryCompactionCompleted, size, sizeAddedPreOperation, snapshot, startReplayingFromWAL, stopReplayingFromWAL, swapCompactedSegments, 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

    • MyCompactingMemStore4

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

    • getImmutableSegments

      public org.apache.hadoop.hbase.regionserver.VersionedSegmentsList getImmutableSegments()
      Overrides:
      getImmutableSegments in class org.apache.hadoop.hbase.regionserver.CompactingMemStore

    • swapPipelineWithNull

      protected boolean swapPipelineWithNull(org.apache.hadoop.hbase.regionserver.VersionedSegmentsList segments)
      Overrides:
      swapPipelineWithNull in class org.apache.hadoop.hbase.regionserver.CompactingMemStore

    • flattenOneSegment

      public void flattenOneSegment(long requesterVersion, org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action action)
      Overrides:
      flattenOneSegment in class org.apache.hadoop.hbase.regionserver.CompactingMemStore

    • setInMemoryCompactionFlag

      protected boolean setInMemoryCompactionFlag()
      Overrides:
      setInMemoryCompactionFlag in class org.apache.hadoop.hbase.regionserver.CompactingMemStore

    • inMemoryCompaction

      void inMemoryCompaction()
      Overrides:
      inMemoryCompaction in class org.apache.hadoop.hbase.regionserver.CompactingMemStore