FlinkAggregate算子求和、计数案例

更新时间:2023-06-18 10:20:39 阅读: 评论:0

续签合同申请FlinkAggregate算⼦求和、计数案例
聚u惠
白羊座星座图开始前唠嗑
⼩⽩学习⼜碰到问题了。⽤flink做⼀个实时处理项⽬,需要根据key把商品销售量和销售额求出来。之前学的aggregate只会⽤来计数,改⼀改可以求和,但是⼜不能够2个同时进⾏,也不可能分开成2个aggregate算⼦,这就涉及到知识盲区了。上⽹查了很久,还是没有什么头绪尝试了很多⽅法,机缘巧合下发现⾃定义的accumulator居然有奇⽤!
Aggregate算⼦创建⾃定义accumulator同时实现求和、计数功能
⽹上查到的accumulator案例基本都是只能记录⼀个数据的,如下:
看图写话作文
豇豆干
那我们要记录2个数据怎么做呢,可以把accumulator的类型改成Tuple2<>类(3个同理),然后根据你的业务需求,修改⼀下add⽅法中的代码即可。:
权志龙生日这时我们就可以在紧接着的全窗⼝函数中⽤迭代器把tuple中的值取出来啦
如何祛疤
otg接口有什么问题欢迎在评论区⼀起讨论讨论,共同进步!

本文发布于:2023-06-18 10:20:39,感谢您对本站的认可!

本文链接:https://www.wtabcd.cn/fanwen/fan/89/1043869.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:求和   函数   定义   案例   计数   商品   销售额
相关文章
留言与评论(共有 0 条评论)
   
验证码:
推荐文章
排行榜
Copyright ©2019-2022 Comsenz Inc.Powered by © 专利检索| 网站地图