开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

哪位大佬帮忙解答一下: keyby后 使用Reduce,统计的数据是按状态存储吗,

哪位大佬帮忙解答一下: keyby后 使用Reduce,统计的数据是按状态存储吗,还是单纯的存到内存里?有帖子说:ReduceFunction的底层是通过StreamGroupedReduce这个类来运行,看里面 存储历史统计值 是用的 一个获取状态的方法 getPartitionedStatedeca4c5edcf0c4c829b1d97a998d48ee.png

展开
收起
圆葱猪肉包 2023-03-21 14:41:32 183 0
1 条回答
写回答
取消 提交回答
  • 我印象中 存的是个valueState, 至于存在哪 是看你状态后端肯定不会全部在内存中,一般都是缓存少量变动的,更多的存储在状态后端,用的时候临时查询。此回答整理自钉群“【③群】Apache Flink China社区”

    2023-03-21 16:02:25
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载