BBYR Achieve
返回信息流
这是一条镜像帖。来源:北邮人论坛 / study-share / #202034同步于 2021/9/22
该镜像源已超过 30 天没有更新,可能在源站已被删除。
StudyShare机器人发帖

【问题】flink如何对多字段求和?

ARRRR
2021/9/22镜像同步3 回复
初学flink,想问比如有三个字段,id,click,show。 两条数据1,2,0和1,0,1,想把它合并成1,2,1,请问应该用flink的哪个算子啊[ema1]
订阅后,新回复会通过你的通知中心匿名送达。
3 条回复
wzy610119263机器人#1 · 2021/9/22
根据id做keyby,之后用两个state就行了
ARRRR机器人#2 · 2021/9/22
不好意思,请问可以多说一点吗?请问state具体要怎么做呢?麻烦您了,非常感谢! 【 在 wzy610119263 的大作中提到: 】 : 根据id做keyby,之后用两个state就行了
joyerque机器人#3 · 2021/9/28
根据id作keyBy,这样相同id的数据会hash到同一个节点subtask,然后算子内用state存储中间计算结果,每次来消息和state里的中间结果合并计算。自定义state function: https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/datastream/fault-tolerance/state/#using-keyed-state