Package org.apache.cassandra.db.compaction

Class PendingRepairHolder

java.lang.Object

org.apache.cassandra.db.compaction.AbstractStrategyHolder

org.apache.cassandra.db.compaction.PendingRepairHolder

public class PendingRepairHolder
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
PendingRepairHolder(ColumnFamilyStore cfs, AbstractStrategyHolder.DestinationRouter router, boolean isTransient)

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)
Collection<AbstractStrategyHolder.TaskSupplier>	getBackgroundTaskSuppliers(long gcBefore)
int	getEstimatedRemainingTasks()
Iterable<org.apache.cassandra.db.compaction.PendingRepairManager>	getManagers()
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	hasDataForSession(TimeUUID sessionID)
boolean	hasPendingRepairSSTable(TimeUUID sessionID, SSTableReader sstable)
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

PendingRepairHolder

public PendingRepairHolder(ColumnFamilyStore cfs,
 AbstractStrategyHolder.DestinationRouter router,
 boolean isTransient)

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

getManagers

public Iterable<org.apache.cassandra.db.compaction.PendingRepairManager> getManagers()

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

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

hasDataForSession

public boolean hasDataForSession(TimeUUID sessionID)

containsSSTable

public boolean containsSSTable(SSTableReader sstable)

Specified by:

containsSSTable in class AbstractStrategyHolder

getEstimatedRemainingTasks

public int getEstimatedRemainingTasks()

Specified by:

getEstimatedRemainingTasks in class AbstractStrategyHolder

hasPendingRepairSSTable

public boolean hasPendingRepairSSTable(TimeUUID sessionID,
 SSTableReader sstable)