Changes between Version 8 and Version 9 of Hadoop_Lab5

Timestamp:

Sep 14, 2009, 11:51:10 AM (16 years ago)

Author:

waue

Comment:

--

Hadoop_Lab5

@@ -287 +287 @@
 import org.apache.hadoop.mapred.Reporter;
 
-public class Map extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> {
+public class mapper extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> {
     private final static IntWritable one = new IntWritable(1);
     private Text word = new Text();
@@ -344 +344 @@
 import org.apache.hadoop.mapred.Reporter;
 
-public class Reduce extends MapReduceBase implements Reducer<Text, IntWritable, Text, IntWritable> {
+public class reducer extends MapReduceBase implements Reducer<Text, IntWritable, Text, IntWritable> {
     public void reduce(Text key, Iterator<IntWritable> values, OutputCollector<Text, IntWritable> output, Reporter reporter) throws IOException {
       int sum = 0;
@@ -403 +403 @@
      conf.setOutputValueClass(IntWritable.class);
 
-     conf.setMapperClass(Map.class);
-     conf.setCombinerClass(Reduce.class);
-     conf.setReducerClass(Reduce.class);
+     conf.setMapperClass(mapper.class);
+     conf.setCombinerClass(reducer.class);
+     conf.setReducerClass(reducer.class);
 
      conf.setInputFormat(TextInputFormat.class);