public class RatioBasedCompactionPolicy extends SortedCompactionPolicy
comConf, storeConfigInfo
Constructor and Description |
---|
RatioBasedCompactionPolicy(Configuration conf,
StoreConfigInformation storeConfigInfo) |
Modifier and Type | Method and Description |
---|---|
protected java.util.ArrayList<HStoreFile> |
applyCompactionPolicy(java.util.ArrayList<HStoreFile> candidates,
boolean mayUseOffPeak,
boolean mayBeStuck)
-- Default minor compaction selection algorithm:
choose CompactSelection from candidates --
First exclude bulk-load files if indicated in configuration.
|
protected CompactionRequestImpl |
createCompactionRequest(java.util.ArrayList<HStoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
boolean |
needsCompaction(java.util.Collection<HStoreFile> storeFiles,
java.util.List<HStoreFile> filesCompacting)
A heuristic method to decide whether to schedule a compaction request
|
void |
setMinThreshold(int minThreshold)
Overwrite min threshold for compaction
|
boolean |
shouldPerformMajorCompaction(java.util.Collection<HStoreFile> filesToCompact) |
checkMinFilesCriteria, filterBulk, getCurrentEligibleFiles, getNextMajorCompactTime, preSelectCompactionForCoprocessor, removeExcessFiles, selectCompaction, skipLargeFiles, throttleCompaction
getConf, setConf
public RatioBasedCompactionPolicy(Configuration conf, StoreConfigInformation storeConfigInfo)
public boolean shouldPerformMajorCompaction(java.util.Collection<HStoreFile> filesToCompact) throws java.io.IOException
shouldPerformMajorCompaction
in class SortedCompactionPolicy
filesToCompact
- Files to compact. Can be null.java.io.IOException
protected CompactionRequestImpl createCompactionRequest(java.util.ArrayList<HStoreFile> candidateSelection, boolean tryingMajor, boolean mayUseOffPeak, boolean mayBeStuck) throws java.io.IOException
createCompactionRequest
in class SortedCompactionPolicy
java.io.IOException
protected java.util.ArrayList<HStoreFile> applyCompactionPolicy(java.util.ArrayList<HStoreFile> candidates, boolean mayUseOffPeak, boolean mayBeStuck) throws java.io.IOException
candidates
- pre-filtratejava.io.IOException
public boolean needsCompaction(java.util.Collection<HStoreFile> storeFiles, java.util.List<HStoreFile> filesCompacting)
needsCompaction
in class SortedCompactionPolicy
storeFiles
- files in the store.filesCompacting
- files being scheduled to compact.public void setMinThreshold(int minThreshold)