Hi, I am a little bit confused about the class hierarchy of DataStream. It has three subclasses: KeyedDataStream, SingleOutputStreamOperator, and SplitDataStream.
1) Why is the name "SingleOutputStreamOperator" (why OPERATOR ??) 2) Is it correct, that a SplitDataStream emit multiple logical output streams, while SingleOutputStreamOperator and KeyedDataStream emit a single logical output stream? => If yes, why is a KeyedDataStream not a subclass of SingleOutputStreamOperator ? 3) a) Why does only SingleOutputStreamOperator has method name()/getName()? b) Why does only SingleOutputStreamOperator has method setParallelism()? c) Should those methods be members of DataStream instead? -Matthias
signature.asc
Description: OpenPGP digital signature