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

Attachment: signature.asc
Description: OpenPGP digital signature

Reply via email to