1

集約データ(mapreduce)を処理していますが、map関数にドキュメントが1つしかない場合、reduceに送信されません。マップ内にドキュメントが1つしかないことを確認したり、強制的にreduceを実行したりする方法はありますか?

更新しました

以下に投稿したように、この問題の解決策は(パフォーマンスが大幅に低下しますが)、常にマップ内の値を計算し、それをemitオブジェクトに追加することです。エミットがreduceを通過する場合、値を適切なグループ計算で上書きします。それ以外の場合は、マップで計算されたとおりに出力されます。

4

0 に答える 0