@InterfaceAudience.Private public abstract class MemStoreCompactionStrategy extends Object
Modifier and Type | Class and Description |
---|---|
static class |
MemStoreCompactionStrategy.Action
Types of actions to be done on the pipeline upon MemStoreCompaction invocation.
|
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 and Description |
---|
MemStoreCompactionStrategy(org.apache.hadoop.conf.Configuration conf,
String cfName) |
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) |
protected static final org.slf4j.Logger LOG
public static final String COMPACTING_MEMSTORE_THRESHOLD_KEY
public static final int COMPACTING_MEMSTORE_THRESHOLD_DEFAULT
protected final int pipelineThreshold
public MemStoreCompactionStrategy(org.apache.hadoop.conf.Configuration conf, String cfName)
public abstract MemStoreCompactionStrategy.Action getAction(VersionedSegmentsList versionedList)
public void updateStats(Segment replacement)
public void resetStats()
protected MemStoreCompactionStrategy.Action simpleMergeOrFlatten(VersionedSegmentsList versionedList, String strategy)
protected MemStoreCompactionStrategy.Action getMergingAction()
protected MemStoreCompactionStrategy.Action getFlattenAction()
protected MemStoreCompactionStrategy.Action compact(VersionedSegmentsList versionedList, String strategyInfo)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.