You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2014/12/28 03:10:34 UTC
cassandra git commit: simplify:
Repository: cassandra
Updated Branches:
refs/heads/trunk 36b287bea -> cfee3da90
simplify:
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/cfee3da9
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/cfee3da9
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/cfee3da9
Branch: refs/heads/trunk
Commit: cfee3da908c685dad3103a497dd70eb9a884df3d
Parents: 36b287b
Author: Dave Brosius <db...@mebigfatguy.com>
Authored: Sat Dec 27 21:09:26 2014 -0500
Committer: Dave Brosius <db...@mebigfatguy.com>
Committed: Sat Dec 27 21:09:26 2014 -0500
----------------------------------------------------------------------
examples/hadoop_cql3_word_count/src/WordCount.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/cfee3da9/examples/hadoop_cql3_word_count/src/WordCount.java
----------------------------------------------------------------------
diff --git a/examples/hadoop_cql3_word_count/src/WordCount.java b/examples/hadoop_cql3_word_count/src/WordCount.java
index 6a2f846..3702a2b 100644
--- a/examples/hadoop_cql3_word_count/src/WordCount.java
+++ b/examples/hadoop_cql3_word_count/src/WordCount.java
@@ -37,12 +37,10 @@ import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
-import org.apache.hadoop.mapreduce.Mapper.Context;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;
import com.datastax.driver.core.Row;
-import java.nio.charset.CharacterCodingException;
/**
* This counts the occurrences of words in ColumnFamily
@@ -122,7 +120,7 @@ public class WordCount extends Configured implements Tool
public void map(Long key, Row row, Context context) throws IOException, InterruptedException
{
String value = row.getString("line");
- logger.debug("read {}:{}={} from {}", new Object[] {key, "line", value, context.getInputSplit()});
+ logger.debug("read {}:{}={} from {}", key, "line", value, context.getInputSplit());
StringTokenizer itr = new StringTokenizer(value);
while (itr.hasMoreTokens())
{