Spark总结（三）——RDD的Action操作_在spark中对rdd的action操作有哪些

作者：爱喝兽奶帝天荒 | 2024-06-19 12:09:35

踩

在spark中对rdd的action操作有哪些

1、foreach操作：对RDD中的每个元素执行f函数操作，返回Unit。

def funOps1(): Unit = {
  var rdd1 = sc.parallelize(List(1, 2, 3, 5, 6))
  rdd1.foreach(println _)
}1
2
3
4

源码：
这里写图片描述

2、saveAsTextFile操作：将数据输出到hdfs上，将RDD中的每个元素映射转变为（Null, e.toString）,然后将其写入HDFS。RDD的每个分区存储为HDFS中的一个Block。
这里写图片描述

def funOps2(): Unit = {
  var rdd1 = sc.parallelize(List(1, 2, 3, 5, 6))
  var rdd2 = rdd1.map(_ + 1)
  rdd2.saveAsTextFile(1
2
3
4

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/爱喝兽奶帝天荒/article/detail/736384