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

Flink什么时候用aggregate()或者process()？

Flink什么时候用aggregate()或者process()？

展开
收起
芯在这 2021-12-09 18:36:21 723 分享 版权

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

1 条回答
写回答
取消 提交回答
  • 真的很搞笑

    aggregate： 增量聚合

    process： 全量聚合

    当计算累加操作时候可以使用aggregate操作。

    当计算窗口内全量数据的时候使用process，例如排序等操作。

    2021-12-09 18:36:31
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版aggregate 实时计算 Flink版process
问答地址：
开发者社区 > 大数据 > 问答
相关问答
在Flink CDC中这里process做了什么复杂操作吗？
68
0
0
Flink CDC 在经过process过程后能保证到sink程序时数据是有序的吗？
113
1
0
Flink CDC在process里面插入/更新/删除数据，初始化阶段数据插入很慢，有解决方法吗？
80
1
0
Flink触发窗口后 没有执行 process是为什么哇？
68
0
0
Flink SQL 如何解决 Group Window Aggregate 中的数据倾斜问题？
233
1
0
flink main方法configuration传的参数为啥在process里的open拿不到？
206
1
0
flink的 process 算子里面的 打印到哪里去了？
101
2
0
有没有大佬知道，flink1.12使用state process api做状态迁移，实际读取的sp路
649
1
0
flink 1.12使用state process api，keyBy 一个scala元组，在sna
1295
1
0
是否从Flink设计角度来说，就不支持在reduce和aggregate
956
1
0