Package org.apache.cassandra.db.compaction

Class CompactionStrategyHolder

java.lang.Object

org.apache.cassandra.db.compaction.AbstractStrategyHolder

org.apache.cassandra.db.compaction.CompactionStrategyHolder

public class CompactionStrategyHolder
extends AbstractStrategyHolder

Nested Class Summary

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

AbstractStrategyHolder.DestinationRouter, AbstractStrategyHolder.GroupedSSTableContainer, AbstractStrategyHolder.TaskSupplier

Field Summary

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

cfs

Constructor Summary

Constructors

Constructor	Description
CompactionStrategyHolder(ColumnFamilyStore cfs, AbstractStrategyHolder.DestinationRouter router, boolean isRepaired)

Method Summary

Modifier and Type	Method	Description
void	addSSTable(SSTableReader sstable)
void	addSSTables(AbstractStrategyHolder.GroupedSSTableContainer sstables)
Iterable<AbstractCompactionStrategy>	allStrategies()
boolean	containsSSTable(SSTableReader sstable)
SSTableMultiWriter	createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker)
AbstractCompactionStrategy	first()
Collection<AbstractStrategyHolder.TaskSupplier>	getBackgroundTaskSuppliers(long gcBefore)
int	getEstimatedRemainingTasks()
Collection<AbstractCompactionTask>	getMaximalTasks(long gcBefore, boolean splitOutput)
List<ISSTableScanner>	getScanners(AbstractStrategyHolder.GroupedSSTableContainer sstables, Collection<Range<Token>> ranges)
AbstractCompactionStrategy	getStrategyFor(SSTableReader sstable)
int	getStrategyIndex(AbstractCompactionStrategy strategy)	Return the directory index the given compaction strategy belongs to, or -1 if it's not held by this holder
Collection<AbstractCompactionTask>	getUserDefinedTasks(AbstractStrategyHolder.GroupedSSTableContainer sstables, long gcBefore)
boolean	managesRepairedGroup(boolean isRepaired, boolean isPendingRepair, boolean isTransient)	SSTables are grouped by their repaired and pending repair status.
void	removeSSTables(AbstractStrategyHolder.GroupedSSTableContainer sstables)
void	replaceSSTables(AbstractStrategyHolder.GroupedSSTableContainer removed, AbstractStrategyHolder.GroupedSSTableContainer added)
void	setStrategyInternal(CompactionParams params, int numTokenPartitions)
void	shutdown()
void	startup()

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

createGroupedSSTableContainer, managesSSTable

Methods inherited from class java.lang.Object

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

Constructor Details

CompactionStrategyHolder

public CompactionStrategyHolder(ColumnFamilyStore cfs,
 AbstractStrategyHolder.DestinationRouter router,
 boolean isRepaired)

Method Details

startup

public void startup()

Specified by:

startup in class AbstractStrategyHolder

shutdown

public void shutdown()

Specified by:

shutdown in class AbstractStrategyHolder

setStrategyInternal

public void setStrategyInternal(CompactionParams params,
 int numTokenPartitions)

Specified by:

setStrategyInternal in class AbstractStrategyHolder

managesRepairedGroup

public boolean managesRepairedGroup(boolean isRepaired,
 boolean isPendingRepair,
 boolean isTransient)

Description copied from class: AbstractStrategyHolder

SSTables are grouped by their repaired and pending repair status. This method determines if this holder holds the sstable for the given repaired/grouped statuses. Holders should be mutually exclusive in the groups they deal with. IOW, if one holder returns true for a given isRepaired/isPendingRepair combo, none of the others should.

Specified by:

managesRepairedGroup in class AbstractStrategyHolder

getStrategyFor

public AbstractCompactionStrategy getStrategyFor(SSTableReader sstable)

Specified by:

getStrategyFor in class AbstractStrategyHolder

allStrategies

public Iterable<AbstractCompactionStrategy> allStrategies()

Specified by:

allStrategies in class AbstractStrategyHolder

getBackgroundTaskSuppliers

public Collection<AbstractStrategyHolder.TaskSupplier> getBackgroundTaskSuppliers(long gcBefore)

Specified by:

getBackgroundTaskSuppliers in class AbstractStrategyHolder

getMaximalTasks

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

Specified by:

getMaximalTasks in class AbstractStrategyHolder

getUserDefinedTasks

public Collection<AbstractCompactionTask> getUserDefinedTasks(AbstractStrategyHolder.GroupedSSTableContainer sstables,
 long gcBefore)

Specified by:

getUserDefinedTasks in class AbstractStrategyHolder

addSSTable

public void addSSTable(SSTableReader sstable)

Specified by:

addSSTable in class AbstractStrategyHolder

addSSTables

public void addSSTables(AbstractStrategyHolder.GroupedSSTableContainer sstables)

Specified by:

addSSTables in class AbstractStrategyHolder

removeSSTables

public void removeSSTables(AbstractStrategyHolder.GroupedSSTableContainer sstables)

Specified by:

removeSSTables in class AbstractStrategyHolder

replaceSSTables

public void replaceSSTables(AbstractStrategyHolder.GroupedSSTableContainer removed,
 AbstractStrategyHolder.GroupedSSTableContainer added)

Specified by:

replaceSSTables in class AbstractStrategyHolder

first

public AbstractCompactionStrategy first()

getScanners

public List<ISSTableScanner> getScanners(AbstractStrategyHolder.GroupedSSTableContainer sstables,
 Collection<Range<Token>> ranges)

Specified by:

getScanners in class AbstractStrategyHolder

createSSTableMultiWriter

public SSTableMultiWriter createSSTableMultiWriter(Descriptor descriptor,
 long keyCount,
 long repairedAt,
 TimeUUID pendingRepair,
 boolean isTransient,
 IntervalSet<CommitLogPosition> commitLogPositions,
 int sstableLevel,
 SerializationHeader header,
 Collection<Index.Group> indexGroups,
 LifecycleNewTracker lifecycleNewTracker)

Specified by:

createSSTableMultiWriter in class AbstractStrategyHolder

getStrategyIndex

public int getStrategyIndex(AbstractCompactionStrategy strategy)

Description copied from class: AbstractStrategyHolder

Return the directory index the given compaction strategy belongs to, or -1 if it's not held by this holder

Specified by:

getStrategyIndex in class AbstractStrategyHolder

containsSSTable

public boolean containsSSTable(SSTableReader sstable)

Specified by:

containsSSTable in class AbstractStrategyHolder

getEstimatedRemainingTasks

public int getEstimatedRemainingTasks()

Specified by:

getEstimatedRemainingTasks in class AbstractStrategyHolder