在 Flink 中将 ProcessWindowFunction 与广播流连接的正确方法是什么？

Question

我有一个运行多个模型的 flink 管道，所以窗口看起来像这样：

DataStream<WindowDeviationResult> aggregatedWindow = keyedStream
                                                        .timeWindow(Time.seconds(window_duration))
                                                        .aggregate( model.getWindowAgreggator(), 
                                                                    model.getWindowProcessor());

我需要将来自另一个流的状态发送到 ProcessWindowFunction 运算符（最后一个）。通常，我会在之前进行连接，然后实现 proceessElement 和 processBroadcastElement。但是因为我将 WindowProcessFuction 传递给 .aggregate 作为第二个参数，所以我不能这样做。您在这里看到哪些选项？

Answer 1

Flink 不支持将广播流连接到窗口操作符。我应该建议使用 KeyedBroadcastProcessFunction 而不是窗口，并实现自己的窗口。通常这并不是特别困难。请参阅 https://stackoverflow.com/a/59823254/2000823 了解可能有助于您入门的示例。