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 int
estimatedRemainingTasks
Deprecated.-
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 void
addSSTable(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.int
getEstimatedRemainingTasks()
Deprecated.java.util.Collection<AbstractCompactionTask>
getMaximalTask(int gcBefore, boolean splitOutput)
Deprecated.long
getMaxSSTableBytes()
Deprecated.AbstractCompactionTask
getNextBackgroundTask(int gcBefore)
Deprecated.protected java.util.Set<SSTableReader>
getSSTables()
Deprecated.Returns the sstables managed by this strategy instanceAbstractCompactionTask
getUserDefinedTask(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 datavoid
removeSSTable(SSTableReader sstable)
Deprecated.Removes sstable from the strategy, implementations must be able to handle the sstable having already been removed.CompactionLogger.Strategy
strategyLogger()
Deprecated.java.lang.String
toString()
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:
getNextBackgroundTask
in 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:AbstractCompactionStrategy
Adds sstable, note that implementations must handle duplicate notifications here (added already being in the compaction strategy)- Specified by:
addSSTable
in classAbstractCompactionStrategy
-
removeSSTable
public void removeSSTable(SSTableReader sstable)
Deprecated.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 classAbstractCompactionStrategy
-
getSSTables
protected java.util.Set<SSTableReader> getSSTables()
Deprecated.Description copied from class:AbstractCompactionStrategy
Returns the sstables managed by this strategy instance- Specified by:
getSSTables
in classAbstractCompactionStrategy
-
getMaximalTask
public java.util.Collection<AbstractCompactionTask> getMaximalTask(int gcBefore, boolean splitOutput)
Deprecated.- Specified by:
getMaximalTask
in 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:
getUserDefinedTask
in 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:
getEstimatedRemainingTasks
in classAbstractCompactionStrategy
- Returns:
- the number of background tasks estimated to still be needed for this columnfamilystore
-
getMaxSSTableBytes
public long getMaxSSTableBytes()
Deprecated.- Specified by:
getMaxSSTableBytes
in 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:
groupSSTablesForAntiCompaction
in 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 ConfigurationException
Deprecated.- Throws:
ConfigurationException
-
strategyLogger
public CompactionLogger.Strategy strategyLogger()
Deprecated.- Overrides:
strategyLogger
in classAbstractCompactionStrategy
-
toString
public java.lang.String toString()
Deprecated.- Overrides:
toString
in classjava.lang.Object
-
-