gpt4 book ai didi

apache-flink - 从 Apache Flink 中的 DataStream 类扩展的 SingleOutputStreamOperator 背后的想法是什么?

转载 作者:行者123 更新时间:2023-12-05 03:03:37 25 4
gpt4 key购买 nike

我在浏览 Apache Flink 源代码时发现 SingleOutputStreamOperator 类是从 DataStream 类扩展而来的。从名称本身看,它看起来像一个运算符,那么为什么不是从 StreamOperator 扩展而是从 DataStream 类扩展。这种设计背后的动机是什么?

最佳答案

SingleOutputStreamOperator 表示应用在具有一种预定义输出类型的 DataStream 上的用户定义转换。从这个意义上说,它是 DataStream 的特化,因为结果也是数据流,但它是转换的结果。

DataStream 也有两种不同的子类型:KeyedStream 表示定义了键的流,SplitStream 包含您可以从中选择多个拆分流。

关于apache-flink - 从 Apache Flink 中的 DataStream 类扩展的 SingleOutputStreamOperator 背后的想法是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53638145/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com