有没有懂 flink 实时计算的老哥，请教一个问题

[zcguo]

我想要计算实时的当日 pv，比如今天是 11 月 16 日，在 11 月 16 日的 3 点要计算一个从 0 点到 3 点时候的 pv，然后 5 点时候要计算一个从 0 点到 5 点的 pv，我看 flink 的滑动窗口和滚动窗口都不能实现这种从固定一个点开始算的需求，该怎么做的这种，谢谢老哥们了

[outoftimeerror]

看你这需求就是求一个累加 和窗口没啥关系

[ebingtel]

是的不支持……可以变通下：第一条流统计每个小时的、输出；再分别起 3h、5h 的两个流……

[ebingtel]

@ebingtel 1 天就 24 个点，感觉后面两个流不用起了……数据库查一下就行了

[picone]

先计算每小时的，存数据库就好了，读取的时候再指定时间。
5 点时候没必要重复计算 0-3 时的 pv

[xiaoidea]

1. 窗口也是基于 state 的，你可以直接在 function 中用 state 作为计数器，计数器的累加根据你的需求可以设计为日期为 key，pv 为 value
2. 使用外部存储，比如 redis，不好的地方是失败恢复时可能导致数据不准

[FireCat]

每小时一个 Window