@InterfaceAudience.Private public class AdaptiveMemStoreCompactionStrategy extends MemStoreCompactionStrategy
MemStoreCompactionStrategy.Action
Modifier and Type | Field and Description |
---|---|
private static double |
ADAPTIVE_COMPACTION_THRESHOLD_DEFAULT |
static String |
ADAPTIVE_COMPACTION_THRESHOLD_KEY |
private static double |
ADAPTIVE_INITIAL_COMPACTION_PROBABILITY_DEFAULT |
static String |
ADAPTIVE_INITIAL_COMPACTION_PROBABILITY_KEY |
private static double |
ADAPTIVE_PROBABILITY_FACTOR |
private boolean |
compacted |
private double |
compactionProbability |
private double |
compactionThreshold |
private double |
initialCompactionProbability |
private static String |
NAME |
private double |
numCellsInVersionedList |
cfName, COMPACTING_MEMSTORE_THRESHOLD_DEFAULT, COMPACTING_MEMSTORE_THRESHOLD_KEY, LOG, pipelineThreshold
Constructor and Description |
---|
AdaptiveMemStoreCompactionStrategy(org.apache.hadoop.conf.Configuration conf,
String cfName) |
Modifier and Type | Method and Description |
---|---|
MemStoreCompactionStrategy.Action |
getAction(VersionedSegmentsList versionedList) |
protected MemStoreCompactionStrategy.Action |
getFlattenAction() |
protected MemStoreCompactionStrategy.Action |
getMergingAction() |
protected String |
getName() |
void |
resetStats() |
void |
updateStats(Segment replacement) |
compact, simpleMergeOrFlatten, toString
private static final String NAME
public static final String ADAPTIVE_COMPACTION_THRESHOLD_KEY
private static final double ADAPTIVE_COMPACTION_THRESHOLD_DEFAULT
public static final String ADAPTIVE_INITIAL_COMPACTION_PROBABILITY_KEY
private static final double ADAPTIVE_INITIAL_COMPACTION_PROBABILITY_DEFAULT
private static final double ADAPTIVE_PROBABILITY_FACTOR
private double compactionThreshold
private double initialCompactionProbability
private double compactionProbability
private double numCellsInVersionedList
private boolean compacted
public AdaptiveMemStoreCompactionStrategy(org.apache.hadoop.conf.Configuration conf, String cfName)
public MemStoreCompactionStrategy.Action getAction(VersionedSegmentsList versionedList)
getAction
in class MemStoreCompactionStrategy
public void updateStats(Segment replacement)
updateStats
in class MemStoreCompactionStrategy
public void resetStats()
resetStats
in class MemStoreCompactionStrategy
protected MemStoreCompactionStrategy.Action getMergingAction()
getMergingAction
in class MemStoreCompactionStrategy
protected MemStoreCompactionStrategy.Action getFlattenAction()
getFlattenAction
in class MemStoreCompactionStrategy
protected String getName()
getName
in class MemStoreCompactionStrategy
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.