特牛网址导航

Spark之行动算子_spark.read.load() 是立即执行的算子吗-CSDN博客

网友收藏
文章浏览阅读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() 是立即执行的算子吗