flink DataStream算子中如何实时更新变量？

Question

我在第一个map需要用到变量currentCenter，然后我输出的结果需要更新currentCenter（最后一个map），但是没办法更新，有什么办法更新吗？

Answer 1

使用数据库、文件都可以解决此问题。但使得算法退化成频繁的io读取算法，所以最后采用了迭代流+广播流的解决方法，动态更新变量！更多介绍看文章：https://segmentfault.com/a/11...