r - Java mapreduce の setup() と cleanup() に似た、R-Hadoop mapreduce のメソッドはありますか?

Question

Java mapreduce の setup() と cleanup() に似た、R-Hadoop mapreduce のメソッドはありますか? すべてのレデューサーを開始する前に、db 呼び出しなどのコードの一部を 1 回だけ実行する必要があります。Rを使用してmapreduceコードを書くときにそれを行うための規定はありますか?

Answer 1

rmr2 について話している場合は、ありません。ユースケースを詳しく説明していただければ、失敗しても代替案を考えたり、何かを学んだりすることができます。この DB アクセスは map と reduce の間で発生する必要があると思いますが、DB 操作が map フェーズの出力に依存するかどうか、reduce フェーズが DB 操作の結果に依存するかどうかを理解することが重要です。私の経験からすると、これは非常にユニークな要件であり、1 つのマップのみと 1 つのリデュースのみの 2 つのジョブで解決する必要があるように思えます。