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?

回复