如何在SparkR中进行映射和归约

Question

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

Answer 1

有关示例（问题本身），请参阅编写从 SparkR:::map 返回的 R 数据帧。简而言之，sph21 引用的博文已经过时了。截至目前，map 和reduce 都已作为私有方法隐藏在SparkR 中——有解决该问题的开放票证。