其实问题还是没描述清楚,所以遇到问题究竟是啥,没发现tumbling window不行。

zhiyuan su <zhiyuan.s...@gmail.com> 于2021年11月22日周一 下午4:59写道:

> 感觉你的场景是近实时累计统计,你可以参考下window TVF 看下是否满足
>
> https://flink-learning.org.cn/article/detail/a8b0895d4271bf6b770927eea214612d?tab=SQL&page=1
> 具体在第2章第一节
>
> Pinjie Huang <pinjie.hu...@afterpay.com.invalid> 于2021年11月22日周一 下午3:52写道:
>
> > Hi friends,
> >
> > Flink 自带的window 有tumlbing sliding 和 session 但是似乎没有event triggerred。
> >
> > 比如说 想知道过去1小时event A trigger的次数,
> >
> > 如果使用tumbling window和1h window
> > |1h | 1h |
> > t=0
> > 在t=1.5h时刻,读取数据,是t=1h 时刻过去一小时的数据,而不是实时的。
> >
> > 使用sliding window 的话需要define非常小的slide,而且依旧可能有延迟。
> >
> > 如果想知道实时的数据,需要基于event来更新state,如何实现event triggered window?
> >
>

回复