AI 助理
备案控制台
开发者社区 问答 正文

Flink程序结构中的Transformation是什么呢?

Flink程序结构中的Transformation是什么呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-08 21:21:47 415 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 游客qg2vswkfykdde

    Transformation是指数据转换的各种操作，也称之为算子，有 Map 、 FlatMap 、 Filter 、 KeyBy 、 Reduce 、 Window等，可以将数据转换计算成想要的数据。

    2021-12-08 22:27:15
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版程序 实时计算 Flink版结构 实时计算 Flink版程序结构
问答地址：
开发者社区 > 大数据 > 问答
相关问答
flink CDAS同步数据至SR serverless ，只把表结构同步过去，就报错，如何解决？
124
1
0
Flink CDC里我用cdc同步mysql数据到mysql，想增加一个表结构变更的通知，该怎么做？
295
3
0
Flink CDC监控mysql，如果源端表的结构发生变化，还是需要用户自己代码实现？
144
1
0
目前阿里DW Flink的实时同步能做到上游结构变更下游跟着变更吗？
201
1
0
flink 是开启binlog功能的，订阅的表也有数据程序不报错，但是消费不出数据来。这是什么原因？
150
1
0
Flink CDC跑联表任务时候，程序的内存会慢慢增大，这个报错是因为什么呢？
216
1
0
flinkcdcSQL处理Kafka数据，json数据是数组的，建表结构该怎么写？[{},{}]。？
143
0
0
Flink mongoDB cdc这个语法结构 with参数这些不应该是吧？
59
1
0
在Flink CDC中，这个啥意思啊?是不是报错，但是程序正常运行
79
1
0
Flink我本地代码有这个配置 程序就卡住了，这个属于正常现象么？
85
0
0