9

RecordReader が実際にどのように機能するかを説明できる人はいますか? プログラムの実行が開始された後、メソッドとnextkeyvalue()メソッドはどのように機能しますか?getCurrentkey()getprogress()

4

2 に答える 2

14

(新しい API): デフォルトの Mapper クラスには、次のような run メソッドがあります。

public void run(Context context) throws IOException, InterruptedException {
    setup(context);
    while (context.nextKeyValue()) {
        map(context.getCurrentKey(), context.getCurrentValue(), context);
    }
    cleanup(context);
}

Context.nextKeyValue()、Context.getCurrentKey()およびメソッドは、メソッドのContext.getCurrentValue()ラッパーですRecordReader。ソース ファイルを参照してくださいsrc/mapred/org/apache/hadoop/mapreduce/MapContext.java。

したがって、このループが実行され、Mapper 実装のmap(K, V, Context)メソッドが呼び出されます。

具体的に、他に知りたいことは何ですか？

于 2012-06-08T10:53:48.383 に答える