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:

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 and Description
private static int	CELL_COUNT
private boolean	flushByteSizeLessThanSmallAndLargeCellSize
private AtomicInteger	flushCounter
private static String	LARGE_CELL_THREAD_NAME
private CyclicBarrier	postCyclicBarrier
private CyclicBarrier	preCyclicBarrier
private static 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 and 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 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)
(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, 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 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

flushCounter

private final AtomicInteger flushCounter

CELL_COUNT

private static final int CELL_COUNT

See Also:

Constant Field Values

flushByteSizeLessThanSmallAndLargeCellSize

private boolean flushByteSizeLessThanSmallAndLargeCellSize

Constructor Detail

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

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()