我制作了一个flink的会话窗口来跟踪我网站中访问者的url。从不活动开始5分钟后结束（会话间隔）flink是否支持一些API来读取活动窗口中的数据，而无需逐个会话完成？
fivyi3re1#
Flink家的Windows DataStream 很灵活。例如，可以定义自定义 Trigger 在将记录添加到窗口或在某个持续时间（例如每分钟）之后发出更新结果的。万一你实施了 Trigger 如果生成早期结果，则需要实现下游运算符或逻辑，以便它能够处理更新的结果。如果使用事件时间会话窗口，则应注意会话窗口可能会合并，即，根据会话间隔和记录中时间戳的最大无序度，当接收到介于两者之间的记录并“连接”它们时，可能会合并两个会话窗口。在这种情况下，检测更新的逻辑需要更复杂一些。
DataStream
Trigger
1条答案
按热度按时间fivyi3re1#
Flink家的Windows
DataStream很灵活。例如，可以定义自定义Trigger在将记录添加到窗口或在某个持续时间（例如每分钟）之后发出更新结果的。万一你实施了Trigger如果生成早期结果，则需要实现下游运算符或逻辑，以便它能够处理更新的结果。如果使用事件时间会话窗口，则应注意会话窗口可能会合并，即，根据会话间隔和记录中时间戳的最大无序度，当接收到介于两者之间的记录并“连接”它们时，可能会合并两个会话窗口。在这种情况下，检测更新的逻辑需要更复杂一些。