mapreduce定义Mapper类的API

在MapReduce中，Mapper类是实现Map函数的关键。Mapper类定义了Map函数的输入和输出类型以及具体的Map函数逻辑。下面是定义Mapper类的API：

public class Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {
  protected void setup(Context context) throws IOException, InterruptedException { }
  protected void map(KEYIN key, VALUEIN value, Context context) throws IOException, InterruptedException { }
  protected void cleanup(Context context) throws IOException, InterruptedException { }
}

Mapper类有四个泛型参数，分别是：

- KEYIN：Map函数的输入键类型
- VALUEIN：Map函数的输入值类型
- KEYOUT：Map函数的输出键类型
- VALUEOUT：Map函数的输出值类型

Mapper类中定义了三个方法：

- setup：在Map函数执行前，执行一次，通常用于初始化工作。
- map：Map函数的核心逻辑，接收一对输入键值对，输出若干个中间结果键值对。
- cleanup：在Map函数执行后，执行一次，通常用于清理工作。

其中，map方法是必须实现的，而setup和cleanup方法可以根据需要选择是否实现。

在实际使用中，我们需要编写一个继承自Mapper类的子类，并重写map方法，实现具体的Map函数逻辑。例如：

public class MyMapper extends Mapper<LongWritable, Text, Text, IntWritable> {
  private final static IntWritable one = new IntWritable(1);
  private Text word = new Text();
  
  public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
    String line = value.toString();
    StringTokenizer tokenizer = new StringTokenizer(line);
    while (tokenizer.hasMoreTokens()) {
      word.set(tokenizer.nextToken());
      context.write(word, one);
    }
  }
}

这个例子中，我们定义了一个MyMapper类，继承自Mapper类，并重写了map方法。在map方法中，我们将输入的文本按照空格分隔成若干个单词，然后遍历每个单词，输出一个中间结果键值对，其中键为单词，值为1。