Package org.apache.cassandra.db.compaction

Class CompactionTask

java.lang.Object

org.apache.cassandra.utils.WrappedRunnable

org.apache.cassandra.db.compaction.AbstractCompactionTask

org.apache.cassandra.db.compaction.CompactionTask

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

LeveledCompactionTask, SSTableSplitter.SplittingCompactionTask, TimeWindowCompactionTask, UnifiedCompactionTask

public class CompactionTask
extends AbstractCompactionTask

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	gcBefore
protected final boolean	keepOriginals
protected static final org.slf4j.Logger	logger
protected static long	totalBytesCompacted

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

cfs, compactionType, isUserDefined, transaction

Constructor Summary

Constructors

Constructor	Description
CompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, long gcBefore)
CompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, long gcBefore, boolean keepOriginals)

Method Summary

Modifier and Type	Method	Description
static long	addToTotalBytesCompacted(long bytesCompacted)
protected boolean	buildCompactionCandidatesForAvailableDiskSpace(Set<SSTableReader> fullyExpiredSSTables, TimeUUID taskId)
protected int	executeInternal(ActiveCompactionsTracker activeCompactions)
CompactionAwareWriter	getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction transaction, Set<SSTableReader> nonExpiredSSTables)
protected CompactionController	getCompactionController(Set<SSTableReader> toCompact)
protected Directories	getDirectories()
static boolean	getIsTransient(Set<SSTableReader> sstables)
protected int	getLevel()
static long	getMaxDataAge(Collection<SSTableReader> sstables)
static long	getMinRepairedAt(Set<SSTableReader> actuallyCompact)
static TimeUUID	getPendingRepair(Set<SSTableReader> sstables)
protected boolean	partialCompactionsAcceptable()
boolean	reduceScopeForLimitedSpace(Set<SSTableReader> nonExpiredSSTables, long expectedSize)
protected void	runMayThrow()	For internal use and testing only.
static String	updateCompactionHistory(TimeUUID taskId, String keyspaceName, String columnFamilyName, long[] mergedRowCounts, long startSize, long endSize, Map<String,String> compactionProperties)

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

execute, setCompactionType, setUserDefined, toString

Methods inherited from class org.apache.cassandra.utils.WrappedRunnable

run

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

gcBefore

protected final long gcBefore

keepOriginals

protected final boolean keepOriginals

totalBytesCompacted

protected static long totalBytesCompacted

Constructor Details

CompactionTask

public CompactionTask(ColumnFamilyStore cfs,
 LifecycleTransaction txn,
 long gcBefore)

CompactionTask

public CompactionTask(ColumnFamilyStore cfs,
 LifecycleTransaction txn,
 long gcBefore,
 boolean keepOriginals)

Method Details

addToTotalBytesCompacted

public static long addToTotalBytesCompacted(long bytesCompacted)

executeInternal

protected int executeInternal(ActiveCompactionsTracker activeCompactions)

Specified by:

executeInternal in class AbstractCompactionTask

reduceScopeForLimitedSpace

public boolean reduceScopeForLimitedSpace(Set<SSTableReader> nonExpiredSSTables,
 long expectedSize)

runMayThrow

protected void runMayThrow()
                    throws Exception

For internal use and testing only. The rest of the system should go through the submit* methods, which are properly serialized. Caller is in charge of marking/unmarking the sstables as compacting.

Specified by:

runMayThrow in class WrappedRunnable

Throws:

Exception

getCompactionAwareWriter

public CompactionAwareWriter getCompactionAwareWriter(ColumnFamilyStore cfs,
 Directories directories,
 LifecycleTransaction transaction,
 Set<SSTableReader> nonExpiredSSTables)

Specified by:

getCompactionAwareWriter in class AbstractCompactionTask

updateCompactionHistory

public static String updateCompactionHistory(TimeUUID taskId,
 String keyspaceName,
 String columnFamilyName,
 long[] mergedRowCounts,
 long startSize,
 long endSize,
 Map<String,String> compactionProperties)

getDirectories

protected Directories getDirectories()

getMinRepairedAt

public static long getMinRepairedAt(Set<SSTableReader> actuallyCompact)

getPendingRepair

public static TimeUUID getPendingRepair(Set<SSTableReader> sstables)

getIsTransient

public static boolean getIsTransient(Set<SSTableReader> sstables)

buildCompactionCandidatesForAvailableDiskSpace

protected boolean buildCompactionCandidatesForAvailableDiskSpace(Set<SSTableReader> fullyExpiredSSTables,
 TimeUUID taskId)

getLevel

protected int getLevel()

getCompactionController

protected CompactionController getCompactionController(Set<SSTableReader> toCompact)

partialCompactionsAcceptable

protected boolean partialCompactionsAcceptable()

getMaxDataAge

public static long getMaxDataAge(Collection<SSTableReader> sstables)