Author: eevans
Date: Thu Sep 1 16:12:15 2011
New Revision: 1164127
URL: http://svn.apache.org/viewvc?rev=1164127&view=rev
Log:
add missing mbean method
Patch by eevans; reviewed by jbellis for CASSANDRA-3117
Modified:
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageServiceMBean.java
Modified:
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java?rev=1164127&r1=1164126&r2=1164127&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
(original)
+++
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
Thu Sep 1 16:12:15 2011
@@ -536,6 +536,11 @@ public class StorageService implements I
return joined;
}
+ public int getCompactionThroughputMbPerSec()
+ {
+ return DatabaseDescriptor.getCompactionThroughputMbPerSec();
+ }
+
public void setCompactionThroughputMbPerSec(int value) {
DatabaseDescriptor.setCompactionThroughputMbPerSec(value);
}
Modified:
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageServiceMBean.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageServiceMBean.java?rev=1164127&r1=1164126&r2=1164127&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageServiceMBean.java
(original)
+++
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageServiceMBean.java
Thu Sep 1 16:12:15 2011
@@ -318,6 +318,7 @@ public interface StorageServiceMBean
public int getExceptionCount();
+ public int getCompactionThroughputMbPerSec();
public void setCompactionThroughputMbPerSec(int value);
public void bulkLoad(String directory);