当前位置:网站首页>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>
边栏推荐
猜你喜欢
ShowMeAI —— Show u 三连
inject() can only be used inside setup() or functional components.
RT-Thread Studio学习(十二)W25Q128(SPI)的读写
研究性学习专题 3_LL(1)语法分析设计原理与实现
Thread类的基本使用。
智能健身动作识别:PP-TinyPose打造AI虚拟健身教练!
学会 Arthas,让你 3 年经验掌握 5 年功力
从零开始的tensorflow小白使用指北
leetcode 22.7.31(1)两数之和 (2)整数除法
The difference between character stream and byte stream
随机推荐
2022的七夕,奉上7个精美的表白代码,同时教大家改源码快速自用
在GBase 8c数据库后台,使用什么样的命令来对gtm、dn节点进行主备切换的操作?
经典递归回溯问题之——解数独(LeetCode 37)
Interpretation of new features | MySQL 8.0 online adjustment REDO
使用单调栈解决接雨水问题——LeetCode 42 接雨水+单调栈说明
从底层看 Redis 的五种数据类型
binder通信实现
BFM模型和Landmarks可视化
GBase 8c数据库集群中,怎么替换节点呢?比如设置A节点为gtm,换到B节点上。
2022-08-02 分析RK817 输出32k clock PMIC_32KOUT_WIFI给WiFi模块 clock 注册devm_clk_hw_register
一天搞定JDBC01:连接数据库并执行sql语句
GBase 8c中怎么查询数据库配置参数,例如datestyle。使用什么函数或者语法呢?
高等代数_证明_幂等矩阵一定能够相似对角化
【论文笔记】Dynamic Convolution: Attention over Convolution Kernels
RT-Thread Studio学习(十一)IIC
redis分布式锁的实现
dalle:zero-shot text-to-image generation
sql在字段重复时 对某个字段根据最新时间取数
【UE虚幻引擎】UE5实现动态导航样条线绘制
ShowMeAI —— Show u 三连