- 综合排序
- 最热优先
- 最新优先
- 来自专栏IfDataBig
Flink Transformation
Flink 的 Transformations 操作主要用于将一个和多个 DataStream 按需转换成新的 DataStream。它主要分为以下三类：
41020编辑于 2022-07-27 - 来自专栏程序人生
Operational Transformation
它背后的技术思想是operational transformation。今天简单讲讲OT。 支撑OT的算法比较复杂，但wikipedia的这幅图讲的比较清楚： ? 3) transformation：任何停留在相同页面的浏览器会接收到服务器的消息，做类似于"git rebase"的事情。
1.5K71发布于 2018-03-28 - 来自专栏行者悟空
Spark RDD的Transformation
RDD的Transformation是指由一个RDD生成新RDD的过程，比如前面使用的flatMap、map、filter操作都返回一个新的RDD对象，类型是MapPartitionsRDD，它是RDD 所有的RDD Transformation都只是生成了RDD之间的计算关系以及计算方法，并没有进行真正的计算。 下图显示了WordCount计算过程中的RDD Transformation生成的RDD对象的依赖关系。 ? RDD Transformation生成的RDD对象的依赖关系 除了RDD创建过程会生成新的RDD外，RDD Transformation也会生成新的RDD，并且设置与前一个RDD的依赖关系。
56840发布于 2018-06-22 - 来自专栏ml
HDUOJ-----Computer Transformation
Computer Transformation Time Limit: 2000/1000 MS (Java/Others) Memory Limit: 65536/32768 K (Java
847110发布于 2018-03-21 - 来自专栏Some studies in imgs
Correction based on affine transformation
the number of detected positioning blocks is greater than or equal to 3, the conditions for affine transformation are met; perform affine transformation on the scanned image, and draw on the transformed image the positions
12210编辑于 2025-10-16 - 来自专栏java编程那点事
transformation操作开发实战
1、map：将集合中每个元素乘以2 2、filter：过滤出集合中的偶数 3、flatMap：将行拆分为单词 4、groupByKey：将每个班级的成绩进行分组 5、reduceByKey：统计每个班级的总分 6、sortByKey：将学生分数进行排序 7、join：打印每个学生的成绩 8、cogroup：打印每个学生的成绩
64120编辑于 2023-02-25 - 来自专栏大数据那些事
Spark（4）——transformation、action、persist
transformation 将一个RDD变成一个新的RDD’ 比如mapreduce中的map操作，将数据集里的元素做处理变成新的元素，形成RDD’。 transformation是不会立刻将结果算出来的，相当于把你的意图记下来，最后还要经过action这样的刺激才会返回计算结果。 如下几个算子属于transformation操作： （1）map（func）操作，上图已经用到 （2）filter（func）操作，将满足函数的元素返回true值并保存，不满足的过滤掉 （3）flatMap （4）union、intersection 求两个RDD之间的并集与交集 （5）groupByKey 将元组中的第0个元素当做key，进行分组 action 就像上面所说的transformation
61010发布于 2020-11-11 - 来自专栏java编程那点事
transformation和action介绍
Spark支持两种RDD操作：transformation和action。 例如，map就是一种transformation操作，它用于将已有RDD的每个元素传入一个自定义的函数，并获取一个新的元素，然后将所有的新元素组成一个新的RDD。 transformation的特点就是lazy特性。lazy特性指的是，如果一个spark应用中只定义了transformation操作，那么即使你执行该应用，这些操作也不会执行。 也就是说，transformation是不会触发spark程序的执行的，它们只是记录了对RDD所做的操作，但是不会自发的执行。 只有当transformation之后，接着执行了一个action操作，那么所有的transformation才会执行。
51020编辑于 2023-02-25 - 来自专栏个人分享
spark transformation与action操作函数
一、Transformation map(func) 返回一个新的分布式数据集，由每个原元素经过函数处理后的新元素组成 filter(func) 返回一个新的数据集，经过fun函数处理后返回值为true 执行transformation操作时，spark并没有开始计算，只是将执行的任务封装成DAG,直到碰到action操作时 才真正提交集群 开始计算。
57220发布于 2018-09-06 - 来自专栏IfDataBig
Transformation 和 Action 常用算子
一、Transformation spark 常用的 Transformation 算子如下表： 对原 RDD 中每个元素运用 func 函数，并生成新的 RDD 下面分别给出这些算子的基本使用示例：
57420编辑于 2022-07-27 - 来自专栏又见苍岚
仿射变换(affine transformation)
zhuanlan.zhihu.com/p/377667045 https://zh.m.wikipedia.org/wiki/仿射变换 https://en.wikipedia.org/wiki/Affine_transformation
2K20编辑于 2023-03-19 - 来自专栏又见苍岚
线性变换(linear transformation)
线性变换 (linear transformation) 是在生活和项目中经常见到的映射方式， 是线性代数(linear algebra)的基本概念，它是一类满足某些特殊性质的变换，本文介绍相关内容。 直线比例保特不变 变换前是原点的，变换后依然是原点 定义描述 线性映射（ linear mapping）是从一个向量空间 V 到另一个向量空间 W 的映射且保持加法运算和数量乘法运算，而线性变换（linear transformation
1.9K40编辑于 2023-03-19 - 来自专栏全栈程序员必看
Codeforces 486C Palindrome Transformation(贪心)
题目链接：Codeforces 486C Palindrome Transformation 题目大意：给定一个字符串，长度N。指针位置P，问说最少花多少步将字符串变成回文串。
17130编辑于 2022-07-10 - 来自专栏个人分享
spark RDD transformation与action函数整理
归类总结RDD的transformation操作: 对一个数据集(1,2,3,3)的RDD进行基本的RDD转化操作 map: 将函数应用于RDD中的每个元素，将返回值构成一个新的RDD eg: rdd.map result:{1,2} cartesian() 与另一个RDD的笛卡尔积 eg:rdd.cartesian(other) result:{(1,3),(1,4),(1,5)....(3,5)} 以上皆为transformation
1.1K20发布于 2018-09-06 - 来自专栏大数据共享
Transformation转换算子之Value类型
思考一个问题？map算子并没有指定分区，但是却是还是4个分区？ 首先 map的数据来源于rdd1;rdd1指定了分区。
75720编辑于 2022-04-27 - 来自专栏大数据共享
Transformation转换算子之Key-Value类型
依样画葫芦娃 我们也许不知道怎么自定义一个分区，那么可以看看spark 自带的是怎么写的；如HashPartitioner
93620编辑于 2022-04-27 - 来自专栏全栈程序员必看
Codeforces 346C Number Transformation II 构造
发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/115207.html原文链接：https://javaforall.cn
15810编辑于 2022-07-11 - 来自专栏大数据成长之路
快速入门Flink (8) —— DataStream 的 Transformation常用操作
本文是快速入门Flink系列的第8篇博客，为大家介绍的是流数据常用的Transformation 操作。关于批数据处理的常用16种算子操作，请参考博主的这篇文章? 《快速入门Flink (5) ——DataSet必知必会的16种Transformation操作(超详细!建议收藏!)》。 码字不易，先赞后看!!! ? ---- 1、DataStream的Transformation 1.1 KeyBy 逻辑上将一个流分成不相交的分区，每个分区包含相同键的元素。在内部，这是通过散列分区来实现的。
76920发布于 2021-01-27 - 来自专栏时悦的学习笔记
Oracle基本参数(STAR_TRANSFORMATION_ENABLED)
如无特殊说明数据库版本为11.2.0.4 ---- STAR_TRANSFORMATION_ENABLED ? 该参数决定基于成本的查询转换是否应用到星型查询中 参数类型:字符串 语法:STAR_TRANSFORMATION_ENABLED = { FALSE | TRUE | TEMP_DISABLE } 通过
62520发布于 2020-08-19 - 来自专栏不温卜火
Spark Core快速入门系列(3) | ＜Transformation＞转换算子
在 RDD 上支持 2 种操作: 1.transformation 从一个已知的 RDD 中创建出来一个新的 RDD 例如: map就是一个transformation. 2.action 在 Spark 中几乎所有的transformation操作都是懒执行的(lazy), 也就是说transformation操作并不会立即计算他们的结果, 而是记住了这个操作.
2.2K20发布于 2020-10-28
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号