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:

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 and Description
private static String	LARGE_CELL_THREAD_NAME
private AtomicInteger	largeCellPreUpdateCounter
private CyclicBarrier	postCyclicBarrier
private CyclicBarrier	preCyclicBarrier
private static String	SMALL_CELL_THREAD_NAME
private 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 and 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 and 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.Cell 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, 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 Detail

LARGE_CELL_THREAD_NAME

private static final String LARGE_CELL_THREAD_NAME

See Also:

Constant Field Values

SMALL_CELL_THREAD_NAME

private static final String SMALL_CELL_THREAD_NAME

See Also:

Constant Field Values

preCyclicBarrier

private final CyclicBarrier preCyclicBarrier

postCyclicBarrier

private final CyclicBarrier postCyclicBarrier

largeCellPreUpdateCounter

private final AtomicInteger largeCellPreUpdateCounter

smallCellPreUpdateCounter

private final AtomicInteger smallCellPreUpdateCounter

Constructor Detail

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 Detail

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.Cell 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