hadoop - Hadoopのclose()メソッドで発行するには?

Question

重複の可能性:
Reducer の close メソッドで発行する方法

マッパークラスのcloseメソッドでマッパーの最終結果を発行するにはどうすればよいですか? 結果はどこに保存する必要がありますか? 誰かが私のためにいくつかのコードを書いて説明できますか? ありがとう。

Answer 1

これは、Reducer の同じ関数に対する同様の回答に基づいた Mapper コードのサンプルです。

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...

    }
}