Package org.apache.cassandra.db.compaction

Class SizeTieredCompactionStrategy

java.lang.Object

org.apache.cassandra.db.compaction.AbstractCompactionStrategy

org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy

public class SizeTieredCompactionStrategy
extends AbstractCompactionStrategy

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.db.compaction.AbstractCompactionStrategy

AbstractCompactionStrategy.ScannerList

Field Summary

Fields

Modifier and Type	Field	Description
protected int	estimatedRemainingTasks
protected SizeTieredCompactionStrategyOptions	sizeTieredOptions
protected final Set<SSTableReader>	sstables

Fields inherited from class org.apache.cassandra.db.compaction.AbstractCompactionStrategy

cfs, COMPACTION_ENABLED, DEFAULT_LOG_ALL_OPTION, DEFAULT_TOMBSTONE_COMPACTION_INTERVAL, DEFAULT_TOMBSTONE_THRESHOLD, DEFAULT_UNCHECKED_TOMBSTONE_COMPACTION_OPTION, disableTombstoneCompactions, isActive, LOG_ALL_OPTION, logAll, ONLY_PURGE_REPAIRED_TOMBSTONES, options, TOMBSTONE_COMPACTION_INTERVAL_OPTION, TOMBSTONE_THRESHOLD_OPTION, tombstoneCompactionInterval, tombstoneThreshold, UNCHECKED_TOMBSTONE_COMPACTION_OPTION, uncheckedTombstoneCompaction

Constructor Summary

Constructors

Constructor	Description
SizeTieredCompactionStrategy(ColumnFamilyStore cfs, Map<String,String> options)

Method Summary

Modifier and Type	Method	Description
void	addSSTable(SSTableReader added)	Adds sstable, note that implementations must handle duplicate notifications here (added already being in the compaction strategy)
static List<Pair<SSTableReader,Long>>	createSSTableAndLengthPairs(Iterable<SSTableReader> sstables)
static <T> List<List<T>>	getBuckets(Collection<Pair<T,Long>> files, double bucketHigh, double bucketLow, long minSSTableSize)
static int	getEstimatedCompactionsByTasks(ColumnFamilyStore cfs, List<List<SSTableReader>> tasks)
int	getEstimatedRemainingTasks()
Collection<AbstractCompactionTask>	getMaximalTask(long gcBefore, boolean splitOutput)
long	getMaxSSTableBytes()
AbstractCompactionTask	getNextBackgroundTask(long gcBefore)
protected Set<SSTableReader>	getSSTables()	Returns the sstables managed by this strategy instance
AbstractCompactionTask	getUserDefinedTask(Collection<SSTableReader> sstables, long gcBefore)
static List<SSTableReader>	mostInterestingBucket(List<List<SSTableReader>> buckets, int minThreshold, int maxThreshold)
void	removeSSTable(SSTableReader sstable)	Removes sstable from the strategy, implementations must be able to handle the sstable having already been removed.
String	toString()
static Map<String,String>	validateOptions(Map<String,String> options)

Methods inherited from class org.apache.cassandra.db.compaction.AbstractCompactionStrategy

addSSTables, createSSTableMultiWriter, filterSuspectSSTables, getCompactionTask, getDirectories, getName, getScanners, getScanners, getScanners, groupSSTablesForAntiCompaction, metadataChanged, pause, removeSSTables, replaceSSTables, resume, shutdown, startup, strategyLogger, supportsEarlyOpen, worthDroppingTombstones

Methods inherited from class java.lang.Object

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

Field Details

sizeTieredOptions

protected SizeTieredCompactionStrategyOptions sizeTieredOptions

estimatedRemainingTasks

protected volatile int estimatedRemainingTasks

sstables

protected final Set<SSTableReader> sstables

Constructor Details

SizeTieredCompactionStrategy

public SizeTieredCompactionStrategy(ColumnFamilyStore cfs,
 Map<String,String> options)

Method Details

mostInterestingBucket

public static List<SSTableReader> mostInterestingBucket(List<List<SSTableReader>> buckets,
 int minThreshold,
 int maxThreshold)

Parameters:

buckets - list of buckets from which to return the most interesting, where "interesting" is the total hotness for reads

minThreshold - minimum number of sstables in a bucket to qualify as interesting

maxThreshold - maximum number of sstables to compact at once (the returned bucket will be trimmed down to this)

Returns:

a bucket (list) of sstables to compact

getNextBackgroundTask

public AbstractCompactionTask getNextBackgroundTask(long gcBefore)

Specified by:

getNextBackgroundTask in class AbstractCompactionStrategy

Parameters:

gcBefore - throw away tombstones older than this

Returns:

the next background/minor compaction task to run; null if nothing to do. Is responsible for marking its sstables as compaction-pending.

getMaximalTask

public Collection<AbstractCompactionTask> getMaximalTask(long gcBefore,
 boolean splitOutput)

Specified by:

getMaximalTask in class AbstractCompactionStrategy

Parameters:

gcBefore - throw away tombstones older than this

Returns:

a compaction task that should be run to compact this columnfamilystore as much as possible. Null if nothing to do. Is responsible for marking its sstables as compaction-pending.

getUserDefinedTask

public AbstractCompactionTask getUserDefinedTask(Collection<SSTableReader> sstables,
 long gcBefore)

Specified by:

getUserDefinedTask in class AbstractCompactionStrategy

Parameters:

sstables - SSTables to compact. Must be marked as compacting.

gcBefore - throw away tombstones older than this

Returns:

a compaction task corresponding to the requested sstables. Will not be null. (Will throw if user requests an invalid compaction.) Is responsible for marking its sstables as compaction-pending.

getEstimatedRemainingTasks

public int getEstimatedRemainingTasks()

Specified by:

getEstimatedRemainingTasks in class AbstractCompactionStrategy

Returns:

the number of background tasks estimated to still be needed for this columnfamilystore

createSSTableAndLengthPairs

public static List<Pair<SSTableReader,Long>> createSSTableAndLengthPairs(Iterable<SSTableReader> sstables)

getBuckets

public static <T> List<List<T>> getBuckets(Collection<Pair<T,Long>> files,
 double bucketHigh,
 double bucketLow,
 long minSSTableSize)

getEstimatedCompactionsByTasks

public static int getEstimatedCompactionsByTasks(ColumnFamilyStore cfs,
 List<List<SSTableReader>> tasks)

getMaxSSTableBytes

public long getMaxSSTableBytes()

Specified by:

getMaxSSTableBytes in class AbstractCompactionStrategy

Returns:

size in bytes of the largest sstables for this strategy

validateOptions

public static Map<String,String> validateOptions(Map<String,String> options)
                                          throws ConfigurationException

Throws:

ConfigurationException

addSSTable

public void addSSTable(SSTableReader added)

Description copied from class: AbstractCompactionStrategy

Adds sstable, note that implementations must handle duplicate notifications here (added already being in the compaction strategy)

Specified by:

addSSTable in class AbstractCompactionStrategy

removeSSTable

public void removeSSTable(SSTableReader sstable)

Description copied from class: AbstractCompactionStrategy

Removes sstable from the strategy, implementations must be able to handle the sstable having already been removed.

Specified by:

removeSSTable in class AbstractCompactionStrategy

getSSTables

protected Set<SSTableReader> getSSTables()

Description copied from class: AbstractCompactionStrategy

Returns the sstables managed by this strategy instance

Specified by:

getSSTables in class AbstractCompactionStrategy

toString

public String toString()

Overrides:

toString in class Object