Flink 中的广播"JOIN"

Question

有什么方法可以像在 SPARK 中使用一样在 FLINK 中使用广播加入。我正在使用 JOINS，但数据很大，所以我需要广播加入。

谢谢

Answer 1

Flink 不提供像 Spark 那样的广播联接。使用BroadcastProcessFunction自己实现一个很容易，但我想知道它是否真的合适。仅当两个流中的一个相当小时，广播联接才有意义，否则键分区联接更有意义。

要实现这一点，请广播较小的模式流并将其连接到事件流。在 BroadcastProcessFunction 的 processBroadcastElement 方法中，存储新模式，并在 processElement 方法中查找相关模式并将其与正在处理的事件组合在一起。