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?