mapreduce - マッパー output.collect()?

Question

マッパーはこれを 2 回呼び出します。

out.collect(new Text("Car"),new Text("Subaru");
out.collect(new Text("Cr-v"),new Text("Honda");

reduce()も 2 回呼び出されますか?

Answer 1

私はあなたが話していると仮定しますOutputCollector.collect(K,V)?

reduce()[key, (list of values)] ペアごとに 1 回呼び出されます。説明するために、あなたが電話したとしましょう：

out.collect(new Text("Car"),new Text("Subaru");
out.collect(new Text("Car"),new Text("Honda");
out.collect(new Text("Car"),new Text("Ford");
out.collect(new Text("Truck"),new Text("Dodge");
out.collect(new Text("Truck"),new Text("Chevy");

次にreduce()、ペアで2回呼び出されます

reduce(Car, <Subaru, Honda, Ford>)
reduce(Truck, <Dodge, Chevy>)

したがって、あなたの例では、はい、関数reduce()は2回呼び出されます。それが役立つことを願っています。