如何访问在flink地图外声明的java变量?

Question

我正在Java中创建一个列表。我想分享列表内的地图功能在flink。如何跨flink进程共享变量

要求我有静态数据记录(少于1000条记录)。我想把这些记录和数据流连接起来。

Answer 1

Flink在设计时考虑了可伸缩性，因此它体现了无共享方法。操作符可以是有状态的，但它的状态严格是本地的，对其他操作符不可见。

在这种特殊情况下，一个好的解决方案可能是使用RichMapFunction(或RichFlatMapFunction)进行连接，并在open方法中将所有静态数据记录的副本加载到本地瞬态数据结构中。