natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

switch to int for count output

This commit is contained in:
Jonathan Ellis 2012-01-20 17:31:47 -06:00
parent d51d6f0b43
commit 5409af4535
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/hadoop_word_count/src/WordCount.java
View File

@ -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();

4
examples/hadoop_word_count/src/WordCountSetup.java
View File

@ -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");