RDD 入门_FlatMap 算子|学习笔记

简介: 快速学习 RDD 入门_FlatMap 算子

开发者学堂课程【大数据 Spark2020最新课程(知识精讲与实战演练)第一阶段RDD 入门_FlatMap 算子本地文件读取】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/688/detail/11954


RDD 入门_FlatMap 算子

flatmap 算子

Flatmap 有转换的作用,但是它可以把数组和集合展开,并且 flatmap 中的函数一般也是集合或者数组。

主要作用:

flatmap 算子和 map 算子类似,但是 flatmap 是一对多的情况。

image.png由图可知:

左边框架为 RDD1, 右边框架为 RDD2,中间为计算过程。

将 RDD1 调离 flatmap 时,本质上经历三步骤:

rdd1 编写,将 rdd1中的数据转换为 list 形式,调用字符串的 split 即返回一个 array ,然后将 list 展平成三条或者两条。

一条为: “Holle”,

一条为: “Lily”.

其内部分为两步,首先把 rdd 中的数据转换成为一个数组形式或集合形式,其次把集合或者数组展开,最后生成了多条数据。

进入 ide 创建新的方法,

编写如下:

@Test

Def flatmapTest( ):Unit ={

//1.创建 RDD

val rdd1 = sc.parallelize(Seq(“Hello lily”, “Hello lucy”,

“Hello Tim”))

//2.处理数据

val rdd2 =rdd1.flatmap(item =>item.split(regex= “”))

//3.得到结果

val result = rdd2.collect()

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

//4.关闭 sc

sc.stop()

运行结果如图所示:

image.png

相关文章
|
3天前
|
数据采集 人工智能 安全
|
12天前
|
云安全 监控 安全
|
4天前
|
自然语言处理 API
万相 Wan2.6 全新升级发布!人人都能当导演的时代来了
通义万相2.6全新升级,支持文生图、图生视频、文生视频,打造电影级创作体验。智能分镜、角色扮演、音画同步,让创意一键成片,大众也能轻松制作高质量短视频。
1046 151
|
4天前
|
编解码 人工智能 机器人
通义万相2.6,模型使用指南
智能分镜 | 多镜头叙事 | 支持15秒视频生成 | 高品质声音生成 | 多人稳定对话
|
17天前
|
机器学习/深度学习 人工智能 自然语言处理
Z-Image:冲击体验上限的下一代图像生成模型
通义实验室推出全新文生图模型Z-Image,以6B参数实现“快、稳、轻、准”突破。Turbo版本仅需8步亚秒级生成,支持16GB显存设备,中英双语理解与文字渲染尤为出色,真实感和美学表现媲美国际顶尖模型,被誉为“最值得关注的开源生图模型之一”。
1733 9
|
9天前
|
人工智能 自然语言处理 API
一句话生成拓扑图!AI+Draw.io 封神开源组合,工具让你的效率爆炸
一句话生成拓扑图!next-ai-draw-io 结合 AI 与 Draw.io,通过自然语言秒出架构图,支持私有部署、免费大模型接口,彻底解放生产力,绘图效率直接爆炸。
683 152
|
11天前
|
人工智能 安全 前端开发
AgentScope Java v1.0 发布,让 Java 开发者轻松构建企业级 Agentic 应用
AgentScope 重磅发布 Java 版本,拥抱企业开发主流技术栈。
647 12
|
6天前
|
SQL 自然语言处理 调度
Agent Skills 的一次工程实践
**本文采用 Agent Skills 实现整体智能体**,开发框架采用 AgentScope,模型使用 **qwen3-max**。Agent Skills 是 Anthropic 新推出的一种有别于mcp server的一种开发方式,用于为 AI **引入可共享的专业技能**。经验封装到**可发现、可复用的能力单元**中,每个技能以文件夹形式存在,包含特定任务的指导性说明(SKILL.md 文件)、脚本代码和资源等 。大模型可以根据需要动态加载这些技能,从而扩展自身的功能。目前不少国内外的一些框架也开始支持此种的开发方式,详细介绍如下。
409 4