Hi,
Can someone explain how and where a stream operator is mapped to a stream task. I am particularly interested in the way the stream outputs are created and attached to the operators. I saw that this happen in OperatorChain functions but I do not have the picture of the lifecycle of an stream operator that you would create to its mapping to the task and assignment of the output binding.
