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:

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 and Description
private CountDownLatch	getScannerLatch
private CountDownLatch	snapshotLatch
private static 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

active, FIXED_OVERHEAD, regionServices, snapshot, snapshotId

Constructor Summary

Constructors

Constructor and 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 and Description
protected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>	createList(int capacity)
protected void	pushActiveToPipeline(org.apache.hadoop.hbase.regionserver.MutableSegment active)

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

checkActiveSize, createMemStoreCompactor, debug, flattenOneSegment, flushInMemory, getFamilyName, getFlushableSize, getImmutableSegments, getIndexType, getInmemoryFlushSize, getNextRow, getScanners, getSegments, getSmallestReadPoint, getStore, hasImmutableSegments, heapSize, isMemStoreFlushingInMemory, isSloppy, keySize, preFlushSeqIDEstimation, setCompositeSnapshot, setIndexType, shouldFlushInMemory, size, snapshot, startReplayingFromWAL, stopReplayingFromWAL, swapCompactedSegments, updateLowestUnflushedSequenceIdInWAL

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

add, add, addToScanners, addToScanners, clearSnapshot, dump, getActive, getComparator, getConfiguration, getLowest, getNextRow, getSnapshot, getSnapshotSize, resetActive, timeOfOldestEdit, toString, upsert

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

START_TEST

private static final AtomicBoolean START_TEST

getScannerLatch

private final CountDownLatch getScannerLatch

snapshotLatch

private final CountDownLatch snapshotLatch

Constructor Detail

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 Detail

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)

Overrides:

pushActiveToPipeline in class org.apache.hadoop.hbase.regionserver.CompactingMemStore