如何在 flink 流程序中使用列表等广播变量?

Question

我想在平面图函数或客户触发器中使用其他一些广播资源，例如列表或地图，但我找不到一些可以满足的 api。

我找到了广播方法，但它返回了数据流，我怎样才能将其转换为列表，以及如何在流上下文中获取它？

我使用 Flink-1.3.2。

Answer 1

如果你指的是 Flink 的广播状态，那么这只是在 Flink 1.5 中引入的。

如果您指的是控制记录分区的DataStream#broadcast()，则这不允许你指定广播状态。您必须通过指定相应的CoFlatMapFunction来自己实现它，例如。