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 <dbros...@mebigfatguy.com> Authored: Sat Dec 27 21:09:26 2014 -0500 Committer: Dave Brosius <dbros...@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()) {