org.apache.hadoop.hbase.regionserver

Class MemStoreCompactionStrategy

java.lang.Object

org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy

Direct Known Subclasses:

AdaptiveMemStoreCompactionStrategy, BasicMemStoreCompactionStrategy, EagerMemStoreCompactionStrategy

@InterfaceAudience.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 and Description
static class	MemStoreCompactionStrategy.Action Types of actions to be done on the pipeline upon MemStoreCompaction invocation.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

MemStoreCompactionStrategy

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

Method Detail

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)