svn commit: r934937 - /cassandra/trunk/contrib/word_count/src/WordCountSetup.java

[jbellis]

Author: jbellis
Date: Fri Apr 16 14:46:00 2010
New Revision: 934937

URL: http://svn.apache.org/viewvc?rev=934937&view=rev
Log:
fix contrib/word_count for byte[] keys refactor.  patch by jbellis

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

Modified: cassandra/trunk/contrib/word_count/src/WordCountSetup.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/contrib/word_count/src/WordCountSetup.java?rev=934937&r1=934936&r2=934937&view=diff
==============================================================================
--- cassandra/trunk/contrib/word_count/src/WordCountSetup.java (original)
+++ cassandra/trunk/contrib/word_count/src/WordCountSetup.java Fri Apr 16 
14:46:00 2010
@@ -47,7 +47,7 @@ public class WordCountSetup
 
         // text1: 1 row, 1 word
         columnName = "text1".getBytes();
-        rm = new RowMutation(WordCount.KEYSPACE, "Key0");
+        rm = new RowMutation(WordCount.KEYSPACE, "Key0".getBytes());
         cf = ColumnFamily.create(WordCount.KEYSPACE, WordCount.COLUMN_FAMILY);
         cf.addColumn(new Column(columnName, "word1".getBytes(), 0));
         rm.add(cf);
@@ -56,7 +56,7 @@ public class WordCountSetup
 
         // text2: 1 row, 2 words
         columnName = "text2".getBytes();
-        rm = new RowMutation(WordCount.KEYSPACE, "Key0");
+        rm = new RowMutation(WordCount.KEYSPACE, "Key0".getBytes());
         cf = ColumnFamily.create(WordCount.KEYSPACE, WordCount.COLUMN_FAMILY);
         cf.addColumn(new Column(columnName, "word1 word2".getBytes(), 0));
         rm.add(cf);
@@ -67,7 +67,7 @@ public class WordCountSetup
         columnName = "text3".getBytes();
         for (int i = 0; i < 1000; i++)
         {
-            rm = new RowMutation(WordCount.KEYSPACE, "Key" + i);
+            rm = new RowMutation(WordCount.KEYSPACE, ("Key" + i).getBytes());
             cf = ColumnFamily.create(WordCount.KEYSPACE, 
WordCount.COLUMN_FAMILY);
             cf.addColumn(new Column(columnName, "word1".getBytes(), 0));
             rm.add(cf);