diff --git a/src/java/org/apache/cassandra/db/CompactionManager.java b/src/java/org/apache/cassandra/db/CompactionManager.java index 316e4582a0..18336e2f4c 100644 --- a/src/java/org/apache/cassandra/db/CompactionManager.java +++ b/src/java/org/apache/cassandra/db/CompactionManager.java @@ -33,6 +33,7 @@ import org.slf4j.LoggerFactory; import org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor; +import org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor; import org.apache.cassandra.dht.Range; import org.apache.cassandra.io.*; import org.apache.cassandra.io.sstable.*; @@ -625,7 +626,7 @@ public class CompactionManager implements CompactionManagerMBean public CompactionExecutor() { - super("COMPACTION-POOL"); + super("CompactionExecutor"); } @Override @@ -682,4 +683,9 @@ public class CompactionManager implements CompactionManagerMBean } return n; } + + public long getCompletedTasks() + { + return executor.getTaskCount() - executor.getCompletedTaskCount(); + } } diff --git a/src/java/org/apache/cassandra/db/CompactionManagerMBean.java b/src/java/org/apache/cassandra/db/CompactionManagerMBean.java index 0bb7c3fb4c..719c020aa2 100644 --- a/src/java/org/apache/cassandra/db/CompactionManagerMBean.java +++ b/src/java/org/apache/cassandra/db/CompactionManagerMBean.java @@ -59,4 +59,9 @@ public interface CompactionManagerMBean * @return estimated number of compactions remaining to perform */ public int getPendingTasks(); + + /** + * @return number of completed compactions since server [re]start + */ + public long getCompletedTasks(); }