diff --git a/src/main/java/org/apache/cassandra/service/StorageService.java b/src/main/java/org/apache/cassandra/service/StorageService.java index b59dc4c..01af87f 100644 --- a/src/main/java/org/apache/cassandra/service/StorageService.java +++ b/src/main/java/org/apache/cassandra/service/StorageService.java @@ -582,6 +582,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean, /** * Forces major compaction of a single keyspace */ + @Override public void forceKeyspaceCompaction(String keyspaceName, String... columnFamilies) throws IOException, ExecutionException, InterruptedException { log(" forceKeyspaceCompaction(String keyspaceName, String... columnFamilies) throws IOException, ExecutionException, InterruptedException"); diff --git a/src/main/java/org/apache/cassandra/service/StorageServiceMBean.java b/src/main/java/org/apache/cassandra/service/StorageServiceMBean.java index e9e04dd..a2a723e 100644 --- a/src/main/java/org/apache/cassandra/service/StorageServiceMBean.java +++ b/src/main/java/org/apache/cassandra/service/StorageServiceMBean.java @@ -291,6 +291,12 @@ public interface StorageServiceMBean extends NotificationEmitter { public void forceKeyspaceCompaction(boolean splitOutput, String keyspaceName, String... tableNames) throws IOException, ExecutionException, InterruptedException; + /** + * Forces major compaction of a single keyspace. + */ + public void forceKeyspaceCompaction(String keyspaceName, String... tableNames) + throws IOException, ExecutionException, InterruptedException; + /** * Trigger a cleanup of keys on a single keyspace */