Commit bdd320a7 authored by TRUONG Quang-Huy's avatar TRUONG Quang-Huy

dslkajf

parent 9bee2b87
......@@ -30,7 +30,7 @@ public class Pair extends Configured implements Tool {
// TODO: implement mapper
protected void map(LongWritable key, Text text, Context context) {
//TODO :
//TextPair tp = new TextPair();
TextPair tp = new TextPair();
//context.write(tp, IntWritable(1));
}
......
......@@ -45,7 +45,7 @@ public class WordCountCombiner extends Configured implements Tool {
// TODO: set map class and the map output key and value classes
job.setMapperClass(WCMapperCombiner.class);
job.setMapOutputKeyClass(Text.class);
job.setMapOutputValueClass(IntWritable.class);
job.setMapOutputValueClass(LongWritable.class);
// * TODO: set the combiner class and the combiner output key and value classes
......@@ -57,7 +57,7 @@ public class WordCountCombiner extends Configured implements Tool {
// TODO: set reduce class and the reduce output key and value classes
job.setReducerClass(WCReducerCombiner.class);
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(IntWritable.class);
job.setOutputValueClass(LongWritable.class);
// TODO: set job output format
job.setOutputFormatClass(TextOutputFormat.class);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment