Package org.apache.cassandra.db.compaction

Class AbstractCompactionTask

java.lang.Object

org.apache.cassandra.utils.WrappedRunnable

org.apache.cassandra.db.compaction.AbstractCompactionTask

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

CompactionTask, SingleSSTableLCSTask

public abstract class AbstractCompactionTask
extends WrappedRunnable

Field Summary

Fields

Modifier and Type	Field	Description
protected final ColumnFamilyStore	cfs
protected OperationType	compactionType
protected boolean	isUserDefined
protected LifecycleTransaction	transaction

Constructor Summary

Constructors

Constructor	Description
AbstractCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction transaction)

Method Summary

Modifier and Type	Method	Description
int	execute(ActiveCompactionsTracker activeCompactions)	executes the task and unmarks sstables compacting
protected abstract int	executeInternal(ActiveCompactionsTracker activeCompactions)
abstract CompactionAwareWriter	getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)
AbstractCompactionTask	setCompactionType(OperationType compactionType)
AbstractCompactionTask	setUserDefined(boolean isUserDefined)
String	toString()

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

run, runMayThrow

Methods inherited from class java.lang.Object

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

Field Details

cfs

protected final ColumnFamilyStore cfs

transaction

protected LifecycleTransaction transaction

isUserDefined

protected boolean isUserDefined

compactionType

protected OperationType compactionType

Constructor Details

AbstractCompactionTask

public AbstractCompactionTask(ColumnFamilyStore cfs,
 LifecycleTransaction transaction)

Parameters:

cfs -

transaction - the modifying managing the status of the sstables we're replacing

Method Details

execute

public int execute(ActiveCompactionsTracker activeCompactions)

executes the task and unmarks sstables compacting

getCompactionAwareWriter

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

executeInternal

protected abstract int executeInternal(ActiveCompactionsTracker activeCompactions)

setUserDefined

public AbstractCompactionTask setUserDefined(boolean isUserDefined)

setCompactionType

public AbstractCompactionTask setCompactionType(OperationType compactionType)

toString

public String toString()

Overrides:

toString in class Object