Class DateTieredCompactionStrategy
- java.lang.Object
-
- org.apache.cassandra.db.compaction.AbstractCompactionStrategy
-
- org.apache.cassandra.db.compaction.DateTieredCompactionStrategy
-
@Deprecated public class DateTieredCompactionStrategy extends AbstractCompactionStrategy
Deprecated.in favour ofTimeWindowCompactionStrategy
-
-
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 intestimatedRemainingTasksDeprecated.-
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, TOMBSTONE_COMPACTION_INTERVAL_OPTION, TOMBSTONE_THRESHOLD_OPTION, tombstoneCompactionInterval, tombstoneThreshold, UNCHECKED_TOMBSTONE_COMPACTION_OPTION, uncheckedTombstoneCompaction
-
-
Constructor Summary
Constructors Constructor Description DateTieredCompactionStrategy(ColumnFamilyStore cfs, java.util.Map<java.lang.String,java.lang.String> options)Deprecated.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidaddSSTable(SSTableReader sstable)Deprecated.Adds sstable, note that implementations must handle duplicate notifications here (added already being in the compaction strategy)static java.util.List<Pair<SSTableReader,java.lang.Long>>createSSTableAndMinTimestampPairs(java.lang.Iterable<SSTableReader> sstables)Deprecated.intgetEstimatedRemainingTasks()Deprecated.java.util.Collection<AbstractCompactionTask>getMaximalTask(int gcBefore, boolean splitOutput)Deprecated.longgetMaxSSTableBytes()Deprecated.AbstractCompactionTaskgetNextBackgroundTask(int gcBefore)Deprecated.protected java.util.Set<SSTableReader>getSSTables()Deprecated.Returns the sstables managed by this strategy instanceAbstractCompactionTaskgetUserDefinedTask(java.util.Collection<SSTableReader> sstables, int gcBefore)Deprecated.java.util.Collection<java.util.Collection<SSTableReader>>groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup)Deprecated.DTCS should not group sstables for anticompaction - this can mix new and old datavoidremoveSSTable(SSTableReader sstable)Deprecated.Removes sstable from the strategy, implementations must be able to handle the sstable having already been removed.CompactionLogger.StrategystrategyLogger()Deprecated.java.lang.StringtoString()Deprecated.static java.util.Map<java.lang.String,java.lang.String>validateOptions(java.util.Map<java.lang.String,java.lang.String> options)Deprecated.-
Methods inherited from class org.apache.cassandra.db.compaction.AbstractCompactionStrategy
addSSTables, createSSTableMultiWriter, filterSuspectSSTables, getCompactionTask, getDirectories, getName, getScanners, getScanners, getScanners, metadataChanged, pause, removeSSTables, replaceSSTables, resume, shutdown, startup, supportsEarlyOpen, worthDroppingTombstones
-
-
-
-
Constructor Detail
-
DateTieredCompactionStrategy
public DateTieredCompactionStrategy(ColumnFamilyStore cfs, java.util.Map<java.lang.String,java.lang.String> options)
Deprecated.
-
-
Method Detail
-
getNextBackgroundTask
public AbstractCompactionTask getNextBackgroundTask(int gcBefore)
Deprecated.- Specified by:
getNextBackgroundTaskin classAbstractCompactionStrategy- 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.
-
createSSTableAndMinTimestampPairs
public static java.util.List<Pair<SSTableReader,java.lang.Long>> createSSTableAndMinTimestampPairs(java.lang.Iterable<SSTableReader> sstables)
Deprecated.
-
addSSTable
public void addSSTable(SSTableReader sstable)
Deprecated.Description copied from class:AbstractCompactionStrategyAdds sstable, note that implementations must handle duplicate notifications here (added already being in the compaction strategy)- Specified by:
addSSTablein classAbstractCompactionStrategy
-
removeSSTable
public void removeSSTable(SSTableReader sstable)
Deprecated.Description copied from class:AbstractCompactionStrategyRemoves sstable from the strategy, implementations must be able to handle the sstable having already been removed.- Specified by:
removeSSTablein classAbstractCompactionStrategy
-
getSSTables
protected java.util.Set<SSTableReader> getSSTables()
Deprecated.Description copied from class:AbstractCompactionStrategyReturns the sstables managed by this strategy instance- Specified by:
getSSTablesin classAbstractCompactionStrategy
-
getMaximalTask
public java.util.Collection<AbstractCompactionTask> getMaximalTask(int gcBefore, boolean splitOutput)
Deprecated.- Specified by:
getMaximalTaskin classAbstractCompactionStrategy- 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(java.util.Collection<SSTableReader> sstables, int gcBefore)
Deprecated.- Specified by:
getUserDefinedTaskin classAbstractCompactionStrategy- 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()
Deprecated.- Specified by:
getEstimatedRemainingTasksin classAbstractCompactionStrategy- Returns:
- the number of background tasks estimated to still be needed for this columnfamilystore
-
getMaxSSTableBytes
public long getMaxSSTableBytes()
Deprecated.- Specified by:
getMaxSSTableBytesin classAbstractCompactionStrategy- Returns:
- size in bytes of the largest sstables for this strategy
-
groupSSTablesForAntiCompaction
public java.util.Collection<java.util.Collection<SSTableReader>> groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup)
Deprecated.DTCS should not group sstables for anticompaction - this can mix new and old data- Overrides:
groupSSTablesForAntiCompactionin classAbstractCompactionStrategy
-
validateOptions
public static java.util.Map<java.lang.String,java.lang.String> validateOptions(java.util.Map<java.lang.String,java.lang.String> options) throws ConfigurationExceptionDeprecated.- Throws:
ConfigurationException
-
strategyLogger
public CompactionLogger.Strategy strategyLogger()
Deprecated.- Overrides:
strategyLoggerin classAbstractCompactionStrategy
-
toString
public java.lang.String toString()
Deprecated.- Overrides:
toStringin classjava.lang.Object
-
-