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