如何在 SparkR 中进行 map 和 reduce

【问题标题】：How to do map and reduce in SparkR如何在 SparkR 中进行 map 和 reduce
【发布时间】：2015-09-09 20:11:49
【问题描述】：

如何使用 SparkR 进行映射和归约操作？我能找到的只是关于 SQL 查询的东西。有没有办法使用 SQL 进行 map 和 reduce？

【问题讨论】：

不确定您所说的“使用 SQL 进行映射和缩减”是什么意思，但本教程应该可以帮助您了解如何在 SparkR 中编写映射/缩减：blog.rstudio.org/2015/05/28/sparkr-preview-by-vincent-warmerdam

【解决方案1】：

有关示例（问题本身），请参见 Writing R data frames returned from SparkR:::map。总之，sph21所指的博文已经过时了。截至目前，map 和 reduce 都作为私有方法隐藏在 SparkR 中 - 有解决该问题的公开票。

【讨论】：