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:

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

active, FIXED_OVERHEAD, regionServices, snapshot, snapshotId

Constructor Summary

Constructors

Constructor and 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 and Description
protected org.apache.hadoop.hbase.regionserver.MemStoreCompactor	createMemStoreCompactor(org.apache.hadoop.hbase.MemoryCompactionPolicy compactionPolicy)
protected boolean	shouldFlushInMemory()

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

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

RUNNER_COUNT

private static final AtomicInteger RUNNER_COUNT

Constructor Detail

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 Detail

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

shouldFlushInMemory

protected boolean shouldFlushInMemory()

Overrides:

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