Changes between Version 8 and Version 9 of Hadoop_Lab5


Ignore:
Timestamp:
Sep 14, 2009, 11:51:10 AM (15 years ago)
Author:
waue
Comment:

--

Legend:

Unmodified
Added
Removed
Modified
  • Hadoop_Lab5

    v8 v9  
    287287import org.apache.hadoop.mapred.Reporter;
    288288
    289 public class Map extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> {
     289public class mapper extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> {
    290290    private final static IntWritable one = new IntWritable(1);
    291291    private Text word = new Text();
     
    344344import org.apache.hadoop.mapred.Reporter;
    345345
    346 public class Reduce extends MapReduceBase implements Reducer<Text, IntWritable, Text, IntWritable> {
     346public class reducer extends MapReduceBase implements Reducer<Text, IntWritable, Text, IntWritable> {
    347347    public void reduce(Text key, Iterator<IntWritable> values, OutputCollector<Text, IntWritable> output, Reporter reporter) throws IOException {
    348348      int sum = 0;
     
    403403     conf.setOutputValueClass(IntWritable.class);
    404404
    405      conf.setMapperClass(Map.class);
    406      conf.setCombinerClass(Reduce.class);
    407      conf.setReducerClass(Reduce.class);
     405     conf.setMapperClass(mapper.class);
     406     conf.setCombinerClass(reducer.class);
     407     conf.setReducerClass(reducer.class);
    408408
    409409     conf.setInputFormat(TextInputFormat.class);