FlinkAggregate算⼦求和、计数案例
开始前唠嗑
defined>loan
⼩⽩学习⼜碰到问题了。⽤flink做⼀个实时处理项⽬，需要根据key把商品销售量和销售额求出来。之前学的aggregate只会⽤来计数，改⼀改可以求和，但是⼜不能够2个同时进⾏，也不可能分开成2个aggregate算⼦，这就涉及到知识盲区了。上⽹查了很久，还是没有什么头绪尝试了很多⽅法，机缘巧合下发现⾃定义的accumulator居然有奇⽤！
love and other drugs>无与伦比英文
asif>淘宝培训班Aggregate算⼦创建⾃定义accumulator同时实现求和、计数功能
drown⽹上查到的accumulator案例基本都是只能记录⼀个数据的，如下：
ens
tous那我们要记录2个数据怎么做呢，可以把accumulator的类型改成Tuple2<>类（3个同理），然后根据你的业务需求，修改⼀下add⽅法中的代码即可。：
a级考试这时我们就可以在紧接着的全窗⼝函数中⽤迭代器把tuple中的值取出来啦
有什么问题欢迎在评论区⼀起讨论讨论，共同进步！
