cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r771927 - in /incubator/cassandra/trunk/src/java/org/apache/cassandra/db: ColumnFamilyStore.java ColumnFamilyStoreMBean.java
Date Tue, 05 May 2009 16:56:59 GMT
Author: jbellis
Date: Tue May  5 16:56:55 2009
New Revision: 771927

URL: http://svn.apache.org/viewvc?rev=771927&view=rev
Log:
This patch adds ColumnFamilyStore.forceflush to the mbean so that it can be activated through
the management agent.  patch by Eric Evans; reviewed by jbellis for CASSANDRA-34

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=771927&r1=771926&r2=771927&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 Tue
May  5 16:56:55 2009
@@ -425,7 +425,7 @@
         binaryMemtable_.get().put(key, buffer);
     }
 
-    void forceFlush() throws IOException
+    public void forceFlush()
     {
         memtable_.get().forceflush();
     }

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=771927&r1=771926&r2=771927&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
Tue May  5 16:56:55 2009
@@ -53,4 +53,9 @@
      * @return the number of tasks waiting to run on the memtable executor
      */
     public int getMemtableTasks();
+    
+    /**
+     * Triggers an immediate memtable flush.
+     */
+    public void forceFlush();
 }



Mime
View raw message