apache-flink - 使用 Flink 中的键处理和聚合多个 json

Question

我有一个连续的json流通过kafka，我试图apache flink用一个键加入相同的流。其中 5 个具有相同的键，所以我想使用全局窗口并提供触发器为 5。但问题是，如果只有四个 json 到达而第五个从未到来。我该如何处理这种情况？

标签： apache-flink

Answer 1

进行连接时，您始终需要为连接发生的“窗口”提供一些定义 - 请参阅窗口连接文档。对于纯基于时间的连接，通常使用翻转或滑动窗口。这假设（来自 Kafka 的数据的典型情况）您为每条记录分配了时间戳，然后可以使用这些时间戳来确定哪些事件位于同一时间窗口中。