开发者社区> 问答> 正文

flink疑问

请问:数据流通过算子A时,我想分裂成两个数据流,一个数据流进行算子B操作然后sink,另外一个数据流需要先进行算子C操作,再reduce然后sink,请问这种情况应该如何处理?一个operator中能出来两个不同的数据流吗?*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-07 12:44:36 476 0
1 条回答
写回答
取消 提交回答
  • DataStream ds = .... DataStream ds1 = 直接拿ds 做 B操作                生成的新流,SINK或其它的,你想干什么都可以, DataStream ds2 = 直接拿ds 做 C操作                生成的新流,SINK或其它的,你想干什么都可以, 在DS1,DS2里,DS是同一个流。。。就像SQL中的表一样,它们是一样的东东,其实就是复用,你可以试试。*来自志愿者整理的flink

    2021-12-07 15:30:46
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
《实时计算 Flink 版独家实战秘籍》 立即下载
开源Flink迁移实时计算Flink手册 立即下载
Apache Flink技术进阶 立即下载