Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyCompactingMemStoreWithCustomCompactor

java.lang.Object
org.apache.hadoop.hbase.regionserver.AbstractMemStore
org.apache.hadoop.hbase.regionserver.CompactingMemStore
org.apache.hadoop.hbase.regionserver.TestHStore.MyCompactingMemStoreWithCustomCompactor
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.MemStore
Enclosing class:
TestHStore
public static class TestHStore.MyCompactingMemStoreWithCustomCompactor 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 AtomicInteger
    RUNNER_COUNT
     

    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
    MyCompactingMemStoreWithCustomCompactor(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 org.apache.hadoop.hbase.regionserver.MemStoreCompactor
    createMemStoreCompactor(org.apache.hadoop.hbase.MemoryCompactionPolicy compactionPolicy)
     
    protected boolean
    setInMemoryCompactionFlag()
     

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

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

    • MyCompactingMemStoreWithCustomCompactor

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

    • createMemStoreCompactor

      protected org.apache.hadoop.hbase.regionserver.MemStoreCompactor createMemStoreCompactor(org.apache.hadoop.hbase.MemoryCompactionPolicy compactionPolicy) throws org.apache.hadoop.hbase.exceptions.IllegalArgumentIOException
      Overrides:
      createMemStoreCompactor in class org.apache.hadoop.hbase.regionserver.CompactingMemStore
      Throws:
      org.apache.hadoop.hbase.exceptions.IllegalArgumentIOException

    • setInMemoryCompactionFlag

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