统计最近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之滑动窗口
作者：尤灯塔
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利.