hadoop - 如何在 Hadoop 中的 close() 方法中发出？

Question

可能重复：
如何在 Reducer 的 close 方法中发出

如何在mapper类的close方法中发出 mapper 的最终结果？结果应该存储在哪里？有人可以通过为我编写一些代码来解释它吗？谢谢。

Answer 1

这是一些示例 Mapper 代码，基于 Reducer 中相同功能的类似答案。

public class Map extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> {

    private OutputCollector<Text, IntWritable> collector = null;

    public void map(LongWritable key, Text value, OutputCollector<Text, IntWritable> output, Reporter reporter) throws IOException {

        // Mapper logic goes here

        collector = output;

    }

    public void close() {

        // Write to private variable collector here...

    }
}