MapReduceカウンタ値を特定の値に設定する

Question

MapReduceジョブのカウンタ値を最初から簡単に設定する方法はありませんか？また、マップ/リダクションタスク間のカウンタインクリメントアトミック演算もですか？

Answer 1

最初にカウンタの値を設定することで意味がわからない - カウンタの値を0以外で初期化することを意味します（これを行うためのユースケースは何ですか？）。

アトミック演算の場合、カウンタはタスクごとに孤立して累積されます。タスクが完了すると、カウンタ値はグローバルな合計にコミットされます（コミットされたタスクのみがコミットされるため、投機的に実行される2つのタスクがある場合は、成功したタスクカウンタのみがコミットされます）。

Answer 2

カウンターのように：。

private AtomicInteger pages = new AtomicInteger(0); // total pages fetched 

OR後でいくつかの時点でそれをしたい場合はループ内でincrCounter()メソッドを使用し （。最初のものが優れている）

カウンターを持つ彼らタスクによって維持されていますが関連付けられており、定期的に が送信されますsktracker、次にjobtrackerに渡されるので、それらをグローバルに集約することができます。したがって、各タスクのタスク/リダクションタスクは独自のカウンタ変数のコピーを持ちます。ジョブが成功すると、すべてのカウンターの合計が作成され、出力サマリで提供されます。