apache-spark - SparkR で map と reduce を行う方法

Question

SparkR を使用して操作をマップおよび削減するにはどうすればよいですか? 私が見つけることができるのは、SQLクエリに関するものだけです。SQLを使用してマップと削減を行う方法はありますか?

Answer 1

例 (質問自体) については、SparkR:::map から返された R データ フレームの書き込みを参照してください。つまり、sph21 が参照しているブログ投稿は古くなっています。現在、map と reduce の両方がプライベート メソッドとして SparkR に隠されています。この問題を解決するためのオープン チケットがあります。