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

flink可以通过api获取算子中的内存数据吗?

flink可以通过api获取算子中的内存数据吗?

展开
收起
游客uu65yiq7myioi 2023-02-13 15:46:39 225 0
2 条回答
写回答
取消 提交回答
  • 数据就在reduce算子状态里——该回答整理自钉群“Flink CDC 社区”

    2023-02-13 20:58:36
    赞同 展开评论 打赏
  • 十年摸盘键,代码未曾试。 今日码示君,谁有上云事。

    Flink 可以从各种来源获取数据,然后构建 DataStream 进行转换处理。一般将数据的输入来源称为数据源(data source),而读取数据的算子就是源算子(source operator)。所以,source就是我们整个处理程序的输入端。 Flink 代码中通用的添加 source 的方式,是调用执行环境的 addSource()方法。

    2023-02-13 16:24:09
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    API 平台的安全实践 立即下载
    API 网关实践 立即下载
    云服务器ECS内存增强型实例re6全新发布 立即下载