如何在 SparkR 中进行 map 和 reduce

Question

如何使用 SparkR 进行映射和归约操作？我所能找到的只是关于 SQL 查询的内容。有没有办法使用 SQL 进行映射和减少？

Answer 1

请参阅 示例（问题本身）。简而言之，sph21 引用的博客 post 已过时。截至当前日期，map 和 reduce 都已作为私有方法隐藏在 SparkR 中 - 有解决该问题的公开票证。