org.apache.hadoop.hbase.regionserver

Class TestCompactingMemStore.MyCompactingMemStore

java.lang.Object

org.apache.hadoop.hbase.regionserver.AbstractMemStore

org.apache.hadoop.hbase.regionserver.CompactingMemStore

org.apache.hadoop.hbase.regionserver.TestCompactingMemStore.MyCompactingMemStore

All Implemented Interfaces:

org.apache.hadoop.hbase.regionserver.MemStore

Enclosing class:

TestCompactingMemStore

protected static class TestCompactingMemStore.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 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
MyCompactingMemStore(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.CellComparator 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
(package private) void	disableCompaction()
(package private) void	enableCompaction()
(package private) void	initiateType(org.apache.hadoop.hbase.MemoryCompactionPolicy compactionType, org.apache.hadoop.conf.Configuration conf)

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

checkAndAddToActiveSize, createList, createMemStoreCompactor, 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, 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

Constructor Detail

MyCompactingMemStore

public MyCompactingMemStore(org.apache.hadoop.conf.Configuration conf,
                            org.apache.hadoop.hbase.CellComparator 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

disableCompaction

void disableCompaction()

enableCompaction

void enableCompaction()

initiateType

void initiateType(org.apache.hadoop.hbase.MemoryCompactionPolicy compactionType,
                  org.apache.hadoop.conf.Configuration conf)
           throws org.apache.hadoop.hbase.exceptions.IllegalArgumentIOException

Throws:

org.apache.hadoop.hbase.exceptions.IllegalArgumentIOException