Ignore:
Timestamp:
Jul 17, 2008, 3:35:18 PM (16 years ago)
Author:
waue
Message:

update some new ..

File:
1 edited

Legend:

Unmodified
Added
Removed

  • sample/hadoop-0.16/tw/org/nchc/code/WordCount.java

    r27 r31  
    5656
    5757  // mapper: emits (token, 1) for every word occurrence
    58   private static class MapClass extends MapReduceBase implements
    59       Mapper<LongWritable, Text, Text, IntWritable> {
     58  private static class MapClass extends MapReduceBase
     59  implements Mapper<LongWritable, Text, Text, IntWritable>
     60  {
    6061
    6162    // reuse objects to save overhead of object creation
    … …  
    7778
    7879  // reducer: sums up all the counts
    79   private static class ReduceClass extends MapReduceBase implements
    80       Reducer<Text, IntWritable, Text, IntWritable> {
     80  private static class ReduceClass extends MapReduceBase
     81  implements Reducer<Text, IntWritable, Text, IntWritable>
     82  {
    8183
    8284    // reuse objects
    … …  
    105107    int reduceTasks = 1;
    106108    JobConf conf = new JobConf(WordCount.class);
    107     conf.setJobName("wordcount");
     109//    conf.setJobName("wordcount");
    108110
    109111    conf.setNumMapTasks(mapTasks);
    … …  
    118120
    119121    conf.setMapperClass(MapClass.class);
    120     conf.setCombinerClass(ReduceClass.class);
     122//    conf.setCombinerClass(ReduceClass.class);
    121123    conf.setReducerClass(ReduceClass.class);
    122124
Note: See TracChangeset for help on using the changeset viewer.