Flink应用程序级屏障

Question

我想弄清楚什么是合并Flink中的多个流的障碍的正确方法。

因此，假设我有4个键控流，每个键控流都计算一批数据的汇总统计数据。接下来，我想将这4个数据流的结果组合成一个数据流（Y），并对收到的4个摘要进行一些额外的计算。

的问题是如何使Ÿ节点等待，直到它接收到的所有与X摘要= N之前，X前进= N + 1。 在图片节点发送及其摘要X = N迟于节点发送其X = N + 1 所以节点ý必须等待，直到它接收节点摘要，同时用X缓存摘要=以某种方式从其他节点N + 1。

我在文档中找不到任何类似的东西，所以我非常感谢任何提示。

Answer 1

我想通了，这个任务可以通过简单地做以下来解决：

.keyBy(X) 
.countWindow(4) 
.fold(...)