开发者社区> 问答> 正文

Flink 源码 中OneInputstreamoperator和SingleOutputStreamOperator什么关系?

石权infinite 2019-04-17 10:05:27 366

源码中看到两套概念,不能直观的区分,some one提点下?

在实际执行过程中,可以看到OneInputstreamoperator/TwoInputstreamoperator两个类。

同时,在API中也可以看到SingleOutputStreamOperator,它和前面xxxInputStreamOperator是什么关系?

分享到
取消 提交回答
全部回答(0)
阿里云实时计算
使用钉钉扫一扫加入圈子
+ 订阅

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

推荐文章
相似问题
推荐课程
链接