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

图片.png
我在第一个map需要用到变量currentCenter,然后我输出的结果需要更新currentCenter(最后一个map),但是没办法更新,有什么办法更新吗?

阅读 343
评论
    1 个回答
    • 60

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

      撰写回答

      登录后参与交流、获取后续更新提醒