@InterfaceAudience.Private public class ExploringCompactionPolicy extends RatioBasedCompactionPolicy
comConf, storeConfigInfo
Constructor and Description |
---|
ExploringCompactionPolicy(Configuration conf,
StoreConfigInformation storeConfigInfo)
Constructor for ExploringCompactionPolicy.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.ArrayList<StoreFile> |
applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffPeak,
boolean mightBeStuck)
-- Default minor compaction selection algorithm:
choose CompactSelection from candidates --
First exclude bulk-load files if indicated in configuration.
|
java.util.List<StoreFile> |
applyCompactionPolicy(java.util.List<StoreFile> candidates,
boolean mightBeStuck,
boolean mayUseOffPeak,
int minFiles,
int maxFiles) |
createCompactionRequest, needsCompaction, setMinThreshold, shouldPerformMajorCompaction
checkMinFilesCriteria, filterBulk, getCurrentEligibleFiles, getNextMajorCompactTime, preSelectCompactionForCoprocessor, removeExcessFiles, selectCompaction, skipLargeFiles, throttleCompaction
getConf, setConf
public ExploringCompactionPolicy(Configuration conf, StoreConfigInformation storeConfigInfo)
conf
- The configuration objectstoreConfigInfo
- An object to provide info about the store.protected final java.util.ArrayList<StoreFile> applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates, boolean mayUseOffPeak, boolean mightBeStuck) throws java.io.IOException
RatioBasedCompactionPolicy
applyCompactionPolicy
in class RatioBasedCompactionPolicy
candidates
- pre-filtratejava.io.IOException