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

大佬们 这里为什么用的是flatmap 而不是 map 算子呢?

大佬们 这里为什么用的是flatmap 而不是 map 算子呢? image.png 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

展开
收起
黄一刀 2019-12-10 09:23:44 3883 0
3 条回答
写回答
取消 提交回答
  • 资深java菜鸟

    我的理解是 看入参 如果传进来的是list 就需用用flatmap 如果传进来的是不是list 可以直接用map, 一般keyby出来的结果都是一个list

    2019-12-10 09:53:04
    赞同 展开评论 打赏
  • map的话每个消息都需要有输出,flatMap的话过滤掉的不需要转换,flatMap相当于filter+map

    2019-12-10 09:52:00
    赞同 展开评论 打赏
  • flatmap 是摊平,全部元素摊开

    2019-12-10 09:24:22
    赞同 展开评论 打赏

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

相关电子书

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