Flink 源码 中OneInputstreamoperator和SingleOutputStreamOperator什么关系？
源码中看到两套概念，不能直观的区分，some one提点下？
在实际执行过程中，可以看到OneInputstreamoperator/TwoInputstreamoperator两个类。
同时，在API中也可以看到SingleOutputStreamOperator，它和前面xxxInputStreamOperator是什么关系？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
你好， SingleOutputStreamOperator是继承自DataStream的，仔细比较两个类会发现： 1. SingleOutputStreamOperator是org.apache.flink.streaming.api.datastream包下的，也就是取名虽然是Operator但其实他是一个DataStream，代表的是一个DataStream的transformation，且指定了输出类型。 2. OneInputstreamoperator则是在org.apache.flink.streaming.api.operators，继承自StreamOperator，是用来承接source中流出的数据，这里具体不展开了。
所以，这两个类有不同的表示，SingleOutputStreamOperator是一个DataStream，而OneInputstreamoperator是一个StreamOperator。希望对你有所帮助。
2020-07-03 10:36:58赞同 1 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
