文章浏览阅读1.2k次。1、算子的简单介绍Transformation(转换)算子:根据数据集创建一个新的数据集,计算后返回一个新RDD,例如一个rdd进行map操作后生了一个新的rdd。Action(动作)算子:对rdd结果计算后返回一个数值value给驱动程序(driver),......
2024-01-23 05:04 阅读 阅读全文文章浏览阅读290次。因为转换算子都是懒加载,并不会立即执行,遇到行动算子才执行。目录1.reduce()2.collect()3.count()4.first()5.take()6.takeOrdered()7.aggregate()8.fold()9.countByKey()10.save11.foreach()1.reduce()聚合,f函数聚集RDD中的所有元素,先......
2024-01-23 03:21 阅读 阅读全文