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

simplify:

This commit is contained in:
Dave Brosius 2014-12-27 21:09:26 -05:00
parent 36b287bea4
commit cfee3da908
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
examples/hadoop_cql3_word_count/src/WordCount.java
View File

@ -37,12 +37,10 @@ import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job; import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper; import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer; 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.mapreduce.lib.output.FileOutputFormat;
import org.apache.hadoop.util.Tool; import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner; import org.apache.hadoop.util.ToolRunner;
import com.datastax.driver.core.Row; import com.datastax.driver.core.Row;
import java.nio.charset.CharacterCodingException;
/** /**
* This counts the occurrences of words in ColumnFamily * 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 public void map(Long key, Row row, Context context) throws IOException, InterruptedException
{ {
String value = row.getString("line"); 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); StringTokenizer itr = new StringTokenizer(value);
while (itr.hasMoreTokens()) while (itr.hasMoreTokens())
{ {