我想要计算实时的当日 pv，比如今天是 11 月 16 日，在 11 月 16 日的 3 点要计算一个从 0 点到 3 点时候的 pv，然后 5 点时候要计算一个从 0 点到 5 点的 pv，我看 flink 的滑动窗口和滚动窗口都不能实现这种从固定一个点开始算的需求，该怎么做的这种，谢谢老哥们了
6 条回复 • 2020-11-11 11:54:39 +08:00
 |
1
outoftimeerror 2019 年 11 月 18 日
看你这需求就是求一个累加 和窗口没啥关系
|
 |
2
ebingtel 2019 年 11 月 18 日
是的不支持……可以变通下：第一条流统计每个小时的、输出；再分别起 3h、5h 的两个流……
|
 |
4
picone 2019 年 11 月 18 日
先计算每小时的，存数据库就好了，读取的时候再指定时间。
5 点时候没必要重复计算 0-3 时的 pv |
 |
5
xiaoidea 2019 年 11 月 18 日
1. 窗口也是基于 state 的，你可以直接在 function 中用 state 作为计数器，计数器的累加根据你的需求可以设计为日期为 key，pv 为 value
2. 使用外部存储，比如 redis，不好的地方是失败恢复时可能导致数据不准 |
 |
6
FireCat 2020 年 11 月 11 日
每小时一个 Window
|
• 请不要在回答技术问题时复制粘贴 AI 生成的内容