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

发布于 2022-09-12 02:47:56 字数 143 浏览 15 评论 0

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

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

一页 2022-09-19 02:47:56

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

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文