RDD 算子_ Action _ foreach | 学习笔记

简介: 快速学习 RDD 算子_ Action _ foreach

开发者学堂课程【大数据Spark2020最新课程(知识精讲与实战演练)第二阶段RDD 算子_ Action _ foreach学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/689/detail/11981


RDD 算子_ Action _ foreach


内容介绍

一、前言

二、实例


一、前言

在前面的学习中,我们已经经常使用 collect。在调用 collect 时有一点点繁琐。有一个新的 Action算子可以直接调用,叫做 foreach

 

二、实例

接下来用一个小小的案例来了解一下 foreach。进入工具,创建新方法,定义 RDD ,调用 foreach ,求出数据,打印item 。这时点击 foreach 可以看到它的返回值是一个 Unit

然后运行代码,看看结果是如何的,

代码如下:

@Test

def foreach() : Unit = {

val rdd = sc.parallelize(Seq(1,2,3))

rdd.foreach(item => println(item))

}

1.png

我们可以看到,结果的打印顺序是132,与我们的认知有一点点不同,因为 item 的收集是一个异步的过程,需要大家注意。

相关文章
|
3天前
|
机器学习/深度学习 分布式计算 数据库连接
[Spark精进]必须掌握的4个RDD算子之filter算子
[Spark精进]必须掌握的4个RDD算子之filter算子
52 2
|
9月前
|
存储 分布式计算 对象存储
Spark学习---2、SparkCore(RDD概述、RDD编程(创建、分区规则、转换算子、Action算子))(二)
Spark学习---2、SparkCore(RDD概述、RDD编程(创建、分区规则、转换算子、Action算子))(二)
|
分布式计算 算法 大数据
RDD 算子_ Action _ reduce | 学习笔记
快速学习 RDD 算子_ Action _ reduce
79 0
RDD 算子_ Action _ reduce | 学习笔记
|
分布式计算 大数据 开发者
RDD 算子_ Action _总结 | 学习笔记
快速学习 RDD 算子_ Action _总结
48 0
|
分布式计算 大数据 数据处理
RDD 算子_ Action _ take | 学习笔记
快速学习 RDD 算子_ Action _ take
61 0
RDD 算子_ Action _ take | 学习笔记
|
分布式计算 大数据 调度
RDD 算子_ Action _ countByKey | 学习笔记
快速学习 RDD 算子_ Action _ countByKey
63 0
RDD 算子_ Action _ countByKey | 学习笔记
|
数据采集 分布式计算 大数据
Rdd 算子_转换_filter | 学习笔记
快速学习 Rdd 算子_转换_filter
75 0
Rdd 算子_转换_filter | 学习笔记
|
分布式计算 大数据 API
Rdd 算子_转换_mappartitions | 学习笔记
快速学习 Rdd 算子_转换_mappartitions
120 0
Rdd 算子_转换_mappartitions | 学习笔记
|
分布式计算 大数据 开发者
RDD 算子_转换 join | 学习笔记
快速学习 RDD 算子_转换 join
80 0
RDD 算子_转换 join | 学习笔记
|
分布式计算 大数据 开发者
Rdd 算子_转换_groupbykey | 学习笔记
快速学习 Rdd 算子_转换_groupbykey
113 0
Rdd 算子_转换_groupbykey | 学习笔记