cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r817267 - /incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
Date Mon, 21 Sep 2009 14:22:24 GMT
Author: jbellis
Date: Mon Sep 21 14:22:24 2009
New Revision: 817267

URL: http://svn.apache.org/viewvc?rev=817267&view=rev
Log:
update contrib/CassandraBulkLoader to use getReadStorageEndPoints.  patch by Chris Goffinet;
reviewed by jbellis for CASSANDRA-449

Modified:
    incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java

Modified: incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java?rev=817267&r1=817266&r2=817267&view=diff
==============================================================================
--- incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java (original)
+++ incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java Mon Sep 21 14:22:24
2009
@@ -160,7 +160,7 @@
 
             /* Get serialized message to send to cluster */
             message = createMessage(Keyspace, key.toString(), CFName, columnFamilies);
-            for (EndPoint endpoint: StorageService.instance().getNStorageEndPoint(key.toString()))
+            for (EndPoint endpoint: StorageService.instance().getReadStorageEndPoints(key.toString()))
             {
                 /* Send message to end point */
                 MessagingService.getMessagingInstance().sendOneWay(message, endpoint);
@@ -270,4 +270,4 @@
     {
         runJob(args);
     }
-}
\ No newline at end of file
+}



Mime
View raw message