import org.apache.cassandra.db.compaction.CompactionManager.CompactionExecutorStatsCollector; //导入依赖的package包/类
/**
 * executes the task and unmarks sstables compacting
 */
public int execute(CompactionExecutorStatsCollector collector)
{
    try
    {
        return executeInternal(collector);
    }
    finally
    {
        cfs.getDataTracker().unmarkCompacting(sstables);
    }
}
 

import org.apache.cassandra.db.compaction.CompactionManager.CompactionExecutorStatsCollector; //导入依赖的package包/类
/**
 * executes the task and unmarks sstables compacting
 */
public int execute(CompactionExecutorStatsCollector collector)
{
    try
    {
        return executeInternal(collector);
    }
    finally
    {
        transaction.close();
    }
}
 

import org.apache.cassandra.db.compaction.CompactionManager.CompactionExecutorStatsCollector; //导入依赖的package包/类
protected int executeInternal(CompactionExecutorStatsCollector collector)
{
    this.collector = collector;
    run();
    return sstables.size();
}
 

import org.apache.cassandra.db.compaction.CompactionManager.CompactionExecutorStatsCollector; //导入依赖的package包/类
protected int executeInternal(CompactionExecutorStatsCollector collector)
{
    this.collector = collector;
    run();
    return toCompact.size();
}
 

import org.apache.cassandra.db.compaction.CompactionManager.CompactionExecutorStatsCollector; //导入依赖的package包/类
protected int executeInternal(CompactionExecutorStatsCollector collector)
{
    this.collector = collector;
    run();
    return transaction.originals().size();
}
 

import org.apache.cassandra.db.compaction.CompactionManager.CompactionExecutorStatsCollector; //导入依赖的package包/类
protected abstract int executeInternal(CompactionExecutorStatsCollector collector);