当前位置:网站首页>Explanation of spark operator
Explanation of spark operator
2022-08-04 08:32:00 【这是一本书】
1 Background
An important feature of writing spark programs is based on operator development
Each operator has its own characteristics and uses
A certain type of operator is the performance bottleneck
2 Categories
There are two main categories of spark operators
3 Transformation
3.1 Introduction
Used to transform RDDs
Every Transformation operation will generate a new RDD
This operation is delayed in execution
4 Action
4.1 Introduction
Used to trigger the calculation of RDD; get relevant calculation results or save the results in an external system
5 Summary of the characteristics of the two
Transformation is asynchronous and does not affect performance
Returns the result int, double, and set (will not return a new RDD). When encountering an Action operation, it starts from the source of the lineage and performs physical conversion operations, so the operator of Action consumes performance
/p>
边栏推荐
- 大家好,请教一个问题啊,我们通过flinkcdc把Oracle数据同步到doris,目前的问题是,只
- Shared_preload_libraries导致很多语法不支持
- 新特性解读 | MySQL 8.0 在线调整 REDO
- GBase 8c数据库集群中,怎么替换节点呢?比如设置A节点为gtm,换到B节点上。
- 【高并发基石】多线程、守护线程、线程安全、线程同步、互斥锁
- Mysql insert on duplicate key 死锁问题定位与解决
- 经典动态规划问题的递归实现方法——LeetCode39 组合总和
- C# DirectoryInfo类
- 2022的七夕,奉上7个精美的表白代码,同时教大家改源码快速自用
- 安装GBase 8c数据库的时候,报错显示“Resource:gbase8c already in use”,这怎么处理呢?
猜你喜欢
从零开始C语言精讲篇6:结构体
学会 Arthas,让你 3 年经验掌握 5 年功力
C Language Lectures from Scratch Part 6: Structure
2022-08-02 分析RK817 输出32k clock PMIC_32KOUT_WIFI给WiFi模块 clock 注册devm_clk_hw_register
图的基本概念
The difference between character stream and byte stream
王爽汇编语言第四章:第一个程序
JNI学习1.环境配置与简单函数实现
智能健身动作识别:PP-TinyPose打造AI虚拟健身教练!
华为设备配置VRRP与NQA联动监视上行链路
随机推荐
金仓数据库 KDTS 迁移工具使用指南 (7. 部署常见问题)
binder通信实现
RT-Thread Studio学习(十一)IIC
2022-08-02 分析RK817 输出32k clock PMIC_32KOUT_WIFI给WiFi模块 clock 注册devm_clk_hw_register
金仓数据库的单节点如何转集群?
高等代数_证明_两个矩阵乘积为0,则两个矩阵的秩之和小于等于n
C# DirectoryInfo类
【虚幻引擎UE】UE5实现WEB和UE通讯思路
YOLOv5应用轻量级通用上采样算子CARAFE
The sorting algorithm including selection, bubble, and insertion
Distributed Computing MapReduce | Spark Experiment
秒懂大模型 | 3步搞定AI写摘要
C语言strchr()函数以及strstr()函数的实现
Typora颜色公式代码大全
【高并发基石】多线程、守护线程、线程安全、线程同步、互斥锁
金仓数据库KingbaseES客户端编程接口指南-JDBC(9. JDBC 读写分离)
智汇华云 | 华云软件定义网络 DCI介绍
async - await
「PHP基础知识」转换数据类型
int *p = &a、p = &a、*p = a的正确理解