org.apache.hadoop.hbase.regionserver.compactions

Class EverythingPolicy

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.CompactionPolicy

org.apache.hadoop.hbase.regionserver.compactions.SortedCompactionPolicy

org.apache.hadoop.hbase.regionserver.compactions.RatioBasedCompactionPolicy

org.apache.hadoop.hbase.regionserver.compactions.EverythingPolicy

public class EverythingPolicy
extends RatioBasedCompactionPolicy

Test Policy to compact everything every time.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.regionserver.compactions.CompactionPolicy

comConf, storeConfigInfo

Constructor Summary

Constructors

Constructor and Description
EverythingPolicy(Configuration conf, StoreConfigInformation storeConfigInfo) Constructor.

Method Summary

Modifier and Type	Method and Description
protected ArrayList<StoreFile>	applyCompactionPolicy(ArrayList<StoreFile> candidates, boolean mayUseOffPeak, boolean mayBeStuck) -- Default minor compaction selection algorithm: choose CompactSelection from candidates -- First exclude bulk-load files if indicated in configuration.

Methods inherited from class org.apache.hadoop.hbase.regionserver.compactions.RatioBasedCompactionPolicy

createCompactionRequest, needsCompaction, setMinThreshold, shouldPerformMajorCompaction

Methods inherited from class org.apache.hadoop.hbase.regionserver.compactions.SortedCompactionPolicy

checkMinFilesCriteria, filterBulk, getCurrentEligibleFiles, getNextMajorCompactTime, preSelectCompactionForCoprocessor, removeExcessFiles, selectCompaction, skipLargeFiles, throttleCompaction

Methods inherited from class org.apache.hadoop.hbase.regionserver.compactions.CompactionPolicy

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EverythingPolicy

public EverythingPolicy(Configuration conf,
                        StoreConfigInformation storeConfigInfo)

Constructor.

Parameters:

conf - The Conf.

storeConfigInfo - Info about the store.

Method Detail

applyCompactionPolicy

protected final ArrayList<StoreFile> applyCompactionPolicy(ArrayList<StoreFile> candidates,
                                                           boolean mayUseOffPeak,
                                                           boolean mayBeStuck)
                                                    throws IOException

Description copied from class: RatioBasedCompactionPolicy

-- Default minor compaction selection algorithm: choose CompactSelection from candidates -- First exclude bulk-load files if indicated in configuration. Start at the oldest file and stop when you find the first file that meets compaction criteria: (1) a recently-flushed, small file (i.e. <= minCompactSize) OR (2) within the compactRatio of sum(newer_files) Given normal skew, any newer files will also meet this criteria

Additional Note: If fileSizes.size() >> maxFilesToCompact, we will recurse on compact(). Consider the oldest files first to avoid a situation where we always compact [end-threshold,end). Then, the last file becomes an aggregate of the previous compactions. normal skew: older ----> newer (increasing seqID) _ | | _ | | | | _ --|-|- |-|- |-|---_-------_------- minCompactSize | | | | | | | | _ | | | | | | | | | | | | | | | | | | | | | | | | | |

Overrides:

applyCompactionPolicy in class RatioBasedCompactionPolicy

Parameters:

candidates - pre-filtrate

Returns:

filtered subset

Throws:

IOException