大数据_Flink_数据处理_流处理API_Transform(2)_滚动聚合算子_keyBy_sum_min_max_minBy_maxBy---Flink工作笔记0030

然后我们前面看了基本的转换算子,然后我们再来看

数据聚合相关的算子.

 

我们可以在DataStream中查一下,可以看到,这个里面

竟然没有reduce这样的方法对吧,那怎么办,数据怎么进行聚合啊

我们接着看

 

可以看到我们搜sum,也没有对吧没这样的方法

 

相关文章

Flink-core小总结1.实时计算和离线计算1.1离线计算离线计算的...
2022年7月26日,Taier1.2版本正式发布!本次版本发布更新功能...
关于Flink相关的概念性东西就不说了,网上都有,官网也很详尽...
最近准备用flink对之前项目进行重构,这是一个有挑战(但我很...
Thispostoriginallyappearedonthe ApacheFlinkblog.Itwasre...
Flink配置文件对于管理员来说,差不多经常调整的就只有conf下...