Author: eevans
Date: Fri Jan 22 20:11:21 2010
New Revision: 902249
URL: http://svn.apache.org/viewvc?rev=902249&view=rev
Log:
add new getEndPoints() method
Patch by eevans for CASSANDRA-698
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/tools/NodeProbe.java
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java?rev=902249&r1=902248&r2=902249&view=diff
==============================================================================
---
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java
(original)
+++
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java
Fri Jan 22 20:11:21 2010
@@ -74,6 +74,15 @@
* @return generation number
*/
public int getCurrentGenerationNumber();
+
+ /**
+ * This method returns the N endpoints that are responsible for storing the
+ * specified key i.e for replication.
+ *
+ * @param key - key for which we need to find the endpoint return value -
+ * the endpoint responsible for this key
+ */
+ public List<InetAddress> getNaturalEndpoints(String key);
/**
* Forces major compaction (all sstable files compacted)
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/tools/NodeProbe.java
URL:
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/tools/NodeProbe.java?rev=902249&r1=902248&r2=902249&view=diff
==============================================================================
---
incubator/cassandra/trunk/src/java/org/apache/cassandra/tools/NodeProbe.java
(original)
+++
incubator/cassandra/trunk/src/java/org/apache/cassandra/tools/NodeProbe.java
Fri Jan 22 20:11:21 2010
@@ -24,6 +24,7 @@
import java.lang.management.MemoryMXBean;
import java.lang.management.MemoryUsage;
import java.lang.management.RuntimeMXBean;
+import java.net.InetAddress;
import java.util.AbstractMap;
import java.util.Iterator;
import java.util.List;
@@ -279,6 +280,11 @@
mcmProxy.setMaximumCompactionThreshold(maximumCompactionThreshold);
}
}
+
+ public List<InetAddress> getEndPoints(String key)
+ {
+ return ssProxy.getNaturalEndpoints(key);
+ }
}
class ColumnFamilyStoreMBeanIterator implements Iterator<Map.Entry<String,
ColumnFamilyStoreMBean>>
