我创建了一个Flink的会话窗口来跟踪我站点中访问者的URL。它从不活动开始5分钟后结束(会话间隙)
Flink是否支持某些API来读取活动窗口中的数据而不会按会话间隙完成会话?
Flink的DataStream
中的Windows非常灵活。例如,您可以定义一个自定义Trigger
,它在将记录添加到窗口时或在某个持续时间(例如每分钟)之后发出更新的结果。如果您实现了发布早期结果的Trigger
,则需要实现下游运算符或逻辑,以便能够处理更新的结果。
如果您使用事件时间会话窗口,您应该知道会话窗口可能已合并,即,根据会话间隙和记录中时间戳的最大无序性,可能会合并两个会话窗口收到的记录介于两者之间并“连接”它们。在这种情况下,检测更新的逻辑需要更复杂一些。