网站介绍:文章浏览阅读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中的所有元素,先聚合分区内数据,再聚合分区间数据。 val listRDD: RDD[Int] ..._spark.read.load() 是立即执行的算子吗
- 链接地址:https://blog.csdn.net/lslslslslss/article/details/122917858
- 链接标题:Spark之行动算子_spark.read.load() 是立即执行的算子吗-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:7046
- 网站标签:spark.read.load() 是立即执行的算子吗