统计最近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)))
相关文章
- 10-15flink table窗口聚合的open函数未调用的bug分析
- 10-15绝对差不超过限制的最长连续子数组（ 滑动窗口、multiset / LeetCode）
- 10-15TCP滑动窗口
- 10-15LeetCode30 HashMap 滑动窗口解决 getOrDefault()方法
- 10-15滑动窗口
- 10-15滑动窗口解题模板
- 10-15滑动窗口之LeetCode209长度最小的子数组
- 10-15力扣3. 无重复字符的最长子串---滑动窗口+哈希表
- 10-15718. 最长重复子数组 + 动态规划 + 滑动窗口
- 10-15LeetCode-239-剑指offer-滑动窗口的最大值-队列与栈-python