svn commit: r985424 - /cassandra/trunk/contrib/word_count/src/WordCount.java

[eevans]

Author: eevans
Date: Sat Aug 14 01:48:25 2010
New Revision: 985424

URL: http://svn.apache.org/viewvc?rev=985424&view=rev
Log:
word count fix for changes in CASSANDRA-1322/r984904

Patch by eevans

Modified:
    cassandra/trunk/contrib/word_count/src/WordCount.java

Modified: cassandra/trunk/contrib/word_count/src/WordCount.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/contrib/word_count/src/WordCount.java?rev=985424&r1=985423&r2=985424&view=diff
==============================================================================
--- cassandra/trunk/contrib/word_count/src/WordCount.java (original)
+++ cassandra/trunk/contrib/word_count/src/WordCount.java Sat Aug 14 01:48:25 
2010
@@ -127,7 +127,8 @@ public class WordCount extends Configure
             job.setInputFormatClass(ColumnFamilyInputFormat.class);
             FileOutputFormat.setOutputPath(job, new Path(OUTPUT_PATH_PREFIX + 
i));
 
-            ConfigHelper.setThriftContact(job.getConfiguration(), "localhost", 
 9160);
+            ConfigHelper.setRpcPort(job.getConfiguration(), "9160");
+            ConfigHelper.setInitialAddress(job.getConfiguration(), 
"localhost");
             ConfigHelper.setInputColumnFamily(job.getConfiguration(), 
KEYSPACE, COLUMN_FAMILY);
             SlicePredicate predicate = new 
SlicePredicate().setColumn_names(Arrays.asList(columnName.getBytes()));
             ConfigHelper.setInputSlicePredicate(job.getConfiguration(), 
predicate);