Flink之滑动窗口

统计最近1个小时内的热门商品,并且每隔5分钟更新一次。

 

在1.10版本中

dataStream.keyBy("itemId").timeWindow(Time.hours(1), Time.minutes(5))

在flink的1.12之后版本中 

dataStream.keyBy(_.itemId).window(SlidingEventTimeWindows.of(Time.hours(1), Time.minutes(5)))

 

相关文章

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