Window不评估来自Kafka源的元素

Question

我认为我对Flink窗口的理解可能是错误的，因为它们没有像我期望的那样从文档或Flink书中进行评估。目标是将具有相当静态数据的Kafka主题与具有不断传入数据的Kafka主题连接起来。

env.addSource(createKafkaConsumer())
        .join(env.addSource((createKafkaConsumer()))))
        .where(keySelector())
        .equalTo(keySelector())
        .window(TumblingProcessingTimeWindows.of(Time.hours(2)))
        .apply(new RichJoinFunction<A, B>() { ... }

createKafkaConsumer()返回FlinkKafkaConsumer

keyselector()是我的键选择器的占位符。

我的关键问题：

这里到底发生了什么？是否在窗口完成处理后发出记录？我希望有一个实时输出到水槽，但这将解释很多。

与此相关的是：我可以用onElement触发器处理这个问题吗？或者这会使我的时间窗口过时吗？这两个概念是否并行存在，即连接窗口是2小时，但连接函数+输出是每个元素触发的？那件案子的复制品怎么样？

其他信息：env.setStreamTimeCharacteristic（TimeCharacteristic.ProcessingTime）；已设置，在此期间我还切换到EventTime。

Answer 1

滚动处理时间窗口的语义是它处理落入给定时间范围内的所有事件。在你的情况下，是2小时。默认情况下，窗口只会在2小时结束后输出结果，因为它需要知道该窗口没有其他事件。

如果您希望输出早期结果（例如，针对每个传入记录），那么您可以指定一个自定义的触发器来激发每个元素。有关这方面的更多信息，请参阅触发器API文档。

窗口时间不是从第一个元素开始，而是从窗口长度的倍数开始。例如，如果窗口大小为2小时，则只能有窗口[0,2),[2,4),...而不能有[1,3),[3,5)。