You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/01/24 01:02:38 UTC

svn commit: r902511 - in /incubator/cassandra/trunk/src/java/org/apache/cassandra/db: ColumnFamilyStore.java ColumnFamilyStoreMBean.java

Author: jbellis
Date: Sun Jan 24 00:02:38 2010
New Revision: 902511

URL: http://svn.apache.org/viewvc?rev=902511&view=rev
Log:
add forceMajorCompaction to CFSMbean.  patch by jbellis; reviewed by Eric Evans for CASSANRA-732

Modified:
    incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
    incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java?rev=902511&r1=902510&r2=902511&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java Sun Jan 24 00:02:38 2010
@@ -1146,6 +1146,11 @@
             rowCache.remove(key);
     }
 
+    public void forceMajorCompaction()
+    {
+        CompactionManager.instance.submitMajor(this);
+    }
+
     /**
      * for testing.  no effort is made to clear historical memtables.
      */

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java?rev=902511&r1=902510&r2=902511&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java Sun Jan 24 00:02:38 2010
@@ -98,4 +98,9 @@
      * @return total disk space used by SSTables belonging to this CF, including obsolete ones waiting to be GC'd
      */
     public long getTotalDiskSpaceUsed();
+
+    /**
+     * force a major compaction of this column family
+     */
+    public void forceMajorCompaction();
 }