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)))

标签：itemId,dataStream,Flink,窗口,keyBy,hours,Time,滑动,minutes
来源： https://www.cnblogs.com/30go/p/15416626.html