cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r902511 - in /incubator/cassandra/trunk/src/java/org/apache/cassandra/db: ColumnFamilyStore.java ColumnFamilyStoreMBean.java
Date Sun, 24 Jan 2010 00:02:38 GMT
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();
 }



Mime
View raw message