java - 在 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一个可以帮助您入门的示例。