Flink是否提供了一些API来获取Session Windows中的活动数据?

问题描述 投票:0回答:1

我创建了一个Flink的会话窗口来跟踪我站点中访问者的URL。它从不活动开始5分钟后结束(会话间隙)

Flink是否支持某些API来读取活动窗口中的数据而不会按会话间隙完成会话?

apache-flink flink-streaming
1个回答
0
投票

Flink的DataStream中的Windows非常灵活。例如,您可以定义一个自定义Trigger,它在将记录添加到窗口时或在某个持续时间(例如每分钟)之后发出更新的结果。如果您实现了发布早期结果的Trigger,则需要实现下游运算符或逻辑,以便能够处理更新的结果。

如果您使用事件时间会话窗口,您应该知道会话窗口可能已合并,即,根据会话间隙和记录中时间戳的最大无序性,可能会合并两个会话窗口收到的记录介于两者之间并“连接”它们。在这种情况下,检测更新的逻辑需要更复杂一些。

© www.soinside.com 2019 - 2024. All rights reserved.