问答

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

作者:admin 2021-08-09 我要评论

我在第一个map需要用到变量currentCenter,然后我输出的结果需要更新currentCenter(最后一个map),但是没办法更新,有什么办法更新吗? ### 使用数据库、文件...

在说正事之前,我要推荐一个福利:你还在原价购买阿里云、腾讯云、华为云服务器吗?那太亏啦!来这里,新购、升级、续费都打折,能够为您省60%的钱呢!2核4G企业级云服务器低至69元/年,点击进去看看吧>>>)

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

###

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

版权声明:本文转载自网络,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。本站转载出于传播更多优秀技术知识之目的,如有侵权请联系QQ/微信:153890879删除

相关文章
  • flink DataStream算子中如何实时更新变

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

  • 循环创建数组对象

    循环创建数组对象

  • dolphindb数据库按年分区,应该如何生

    dolphindb数据库按年分区,应该如何生

  • 启动angular+ng-alain项目的时候,ERRO

    启动angular+ng-alain项目的时候,ERRO

腾讯云代理商
海外云服务器