本文继续来看Mapper的实现。

Mapper

01 public static class Map
02         extends Mapper<LongWritable, Text, Text, IntWritable> {
03     private final static IntWritable one = new IntWritable(1);
04     private Text word = new Text();
05
06     public void map(LongWritable key, Text value, Context context)
07             throws IOException, InterruptedException {
08         String line = value.toString();
09         StringTokenizer tokenizer = new StringTokenizer(line);
10         while (tokenizer.hasMoreTokens()) {
11             word.set(tokenizer.nextToken());
12             context.write(word, one);
13         }
14     }
15 }

我们实现了Driver中指定的Map.class，这个类继承自Mapper<LongWritable, Text, Text, IntWritable>，其中四个类型以此是input的key和value，和Mapper输出的Key和Value。

03     private final static IntWritable one = new IntWritable(1);
04     private Text word = new Text();

这两行是定义mapper的输出，看类型就能看出来，Text是mapper输出的key，IntWritable是mapper输出的value。

06     public void map(LongWritable key, Text value, Context context)

继承Mapper就要实现map函数，LongWritable和Text即mapper的输入，Context是mapper和Hadoop系统交互的工具。它可以存储配置数据，还能输出key-value。

getConfiguration()方法返回一个Configuration，里面包含了Hadoop Job的配置数据。程序员可以在配置数据里加入任意的key-value对(例如：Job.getConfiguration().set(“Key”, “Value”))，当然，也可以把它读出来(Context.getConfiguration().get(“Key”))。这种功能一般会在Mapper的setup()方法里面实现。

map(KeyInType, ValInType, Context)是由Mapper.run()方法调用的。map方法处理数据后，通过Context.write(KeyOutType, ValOutType)方法输出。

在mapper结束后，应用程序可以通过重载Mapper的cleanup()方法来做一些需要的收尾工作。

Mapper的输出对的类型不需要和输入对的类型一致，而且给定一个输入对，可以对应于0个或多个输出对。

Context的另一个作用是report progress，可以像Hadoop Job发送任何应用层的状态信息，或者只是告诉别人自己还活着。