Package org.apache.hadoop.hbase.regionserver

Class MemStoreCompactionStrategy

java.lang.Object

org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy

Direct Known Subclasses:

AdaptiveMemStoreCompactionStrategy, BasicMemStoreCompactionStrategy, EagerMemStoreCompactionStrategy

@Private
public abstract class MemStoreCompactionStrategy
extends Object

MemStoreCompactionStrategy is the root of a class hierarchy which defines the strategy for choosing the next action to apply in an (in-memory) memstore compaction. Possible action are: - No-op - do nothing - Flatten - to change the segment's index from CSLM to a flat representation - Merge - to merge the indices of the segments in the pipeline - Compact - to merge the indices while removing data redundancies In addition while applying flat/merge actions it is possible to count the number of unique keys in the result segment.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	MemStoreCompactionStrategy.Action	Types of actions to be done on the pipeline upon MemStoreCompaction invocation.

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	cfName
static final int	COMPACTING_MEMSTORE_THRESHOLD_DEFAULT
static final String	COMPACTING_MEMSTORE_THRESHOLD_KEY
protected static final org.slf4j.Logger	LOG
protected final int	pipelineThreshold

Constructor Summary

Constructors

Constructor	Description
MemStoreCompactionStrategy(org.apache.hadoop.conf.Configuration conf, String cfName)

Method Summary

Modifier and Type	Method	Description
protected MemStoreCompactionStrategy.Action	compact(VersionedSegmentsList versionedList, String strategyInfo)
abstract MemStoreCompactionStrategy.Action	getAction(VersionedSegmentsList versionedList)
protected MemStoreCompactionStrategy.Action	getFlattenAction()
protected MemStoreCompactionStrategy.Action	getMergingAction()
protected abstract String	getName()
void	resetStats()
protected MemStoreCompactionStrategy.Action	simpleMergeOrFlatten(VersionedSegmentsList versionedList, String strategy)
String	toString()
void	updateStats(Segment replacement)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

COMPACTING_MEMSTORE_THRESHOLD_KEY

public static final String COMPACTING_MEMSTORE_THRESHOLD_KEY

See Also:

• Constant Field Values

COMPACTING_MEMSTORE_THRESHOLD_DEFAULT

public static final int COMPACTING_MEMSTORE_THRESHOLD_DEFAULT

See Also:

• Constant Field Values

cfName

protected final String cfName

pipelineThreshold

protected final int pipelineThreshold

Constructor Details

MemStoreCompactionStrategy

public MemStoreCompactionStrategy(org.apache.hadoop.conf.Configuration conf,
 String cfName)

Method Details

toString

public String toString()

Overrides:

toString in class Object

getName

protected abstract String getName()

getAction

public abstract MemStoreCompactionStrategy.Action getAction(VersionedSegmentsList versionedList)

updateStats

public void updateStats(Segment replacement)

resetStats

public void resetStats()

simpleMergeOrFlatten

protected MemStoreCompactionStrategy.Action simpleMergeOrFlatten(VersionedSegmentsList versionedList,
 String strategy)

getMergingAction

protected MemStoreCompactionStrategy.Action getMergingAction()

getFlattenAction

protected MemStoreCompactionStrategy.Action getFlattenAction()

compact

protected MemStoreCompactionStrategy.Action compact(VersionedSegmentsList versionedList,
 String strategyInfo)