From 5409af4535e483103686a4913ea69ab2c68a4b1b Mon Sep 17 00:00:00 2001
From: Jonathan Ellis <jbellis@apache.org>
Date: Fri, 20 Jan 2012 17:31:47 -0600
Subject: [PATCH] switch to int for count output

---
 examples/hadoop_word_count/src/WordCount.java      | 2 +-
 examples/hadoop_word_count/src/WordCountSetup.java | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/examples/hadoop_word_count/src/WordCount.java b/examples/hadoop_word_count/src/WordCount.java
index cdd87d990c..6c203d7456 100644
--- a/examples/hadoop_word_count/src/WordCount.java
+++ b/examples/hadoop_word_count/src/WordCount.java
@@ -137,7 +137,7 @@ public class WordCount extends Configured implements Tool
         {
             Column c = new Column();
             c.setName(Arrays.copyOf(word.getBytes(), word.getLength()));
-            c.setValue(ByteBufferUtil.bytes(String.valueOf(sum)));
+            c.setValue(ByteBufferUtil.bytes(sum));
             c.setTimestamp(System.currentTimeMillis());
 
             Mutation m = new Mutation();
diff --git a/examples/hadoop_word_count/src/WordCountSetup.java b/examples/hadoop_word_count/src/WordCountSetup.java
index 7857f023d4..dd3c824f7d 100644
--- a/examples/hadoop_word_count/src/WordCountSetup.java
+++ b/examples/hadoop_word_count/src/WordCountSetup.java
@@ -132,10 +132,12 @@ public class WordCountSetup
         input.setComparator_type("AsciiType");
         input.setDefault_validation_class("AsciiType");
         cfDefList.add(input);
+
         CfDef output = new CfDef(WordCount.KEYSPACE, WordCount.OUTPUT_COLUMN_FAMILY);
         output.setComparator_type("AsciiType");
-        output.setDefault_validation_class("AsciiType");
+        output.setDefault_validation_class("Int32Type");
         cfDefList.add(output);
+
         CfDef counterInput = new CfDef(WordCount.KEYSPACE, WordCountCounters.COUNTER_COLUMN_FAMILY);
         counterInput.setComparator_type("UTF8Type");
         counterInput.setDefault_validation_class("CounterColumnType");