我正在查看Apache Flink源代码，发现SingleOutputStreamOperator类扩展自DataStream类。 从名称本身看起来像是一个运算符，那么为什么它不是扩展自StreamOperator类而是扩展自DataStream类呢？ 这种设计的动机是什么？
1个回答
4
SingleOutputStreamOperator代表了在DataStream上应用的用户定义转换，具有一个预定义的输出类型。在这个意义上，它是DataStream的一种特化，因为结果也是数据流，但它是转换的结果。
DataStream还有两种不同的子类型：KeyedStream代表已定义键的流，SplitStream包含多个分割流，可以从中选择。
- Till Rohrmann
网页内容由stack overflow 提供, 点击上面的可以查看英文原文，
原文链接
原文链接
- 相关问题
- 3 如何将Apache Flink中的DataStream（源）转换为List？
- 11 Kafka -> Flink DataStream -> MongoDB
- 6 使用Flink获取DataStream的文件名
- 3 Flink：DataStream上没有外连接？
- 5 Apache Flink的分离模式是什么？
- 3 Apache Flink中DataStream和Table API之间的区别
- 3 从JDBC源在DataStream Flink中读取数据的问题
- 8 Apache Flink：DataStream API中的侧输出（side outputs）和split()有什么区别？
- 7 Apache Flink DataStream API 没有 mapPartition 转换。
- 4 Apache Flink中的SlotSharingGroup是什么？