gpt4 book ai didi

java - Apache Flink 中的空窗口

转载 作者:行者123 更新时间:2023-12-02 10:17:24 24 4
gpt4 key购买 nike

我有一个带有事件时间的数据流,是否可以在 Apache Flink 中发出没有数据的窗口?例如,滚动窗口大小为 15 minutes如果我可以清空窗口,如果它们在 [(0, 15), (15, 20), ...] 时间段内没有事件,那就太理想了例如。

最佳答案

不,这是不可能的。 Flink 的窗口运算符仅在第一个事件添加到窗口时创建窗口。

不发出空窗口结果的原因是,窗口通常是在键控流上定义的(如果不键控流,则无法并行处理窗口)。如果 Flink 要在键控流上发出空窗口的记录,则需要为每个可能的键值发出结果。由于可能的键太多,这是不可能的。

关于java - Apache Flink 中的空窗口,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54580982/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com