Hi, Thanks for the answer. Can you point me to the code where the operators are being assign to tasks. Thanks
From: [email protected] [mailto:[email protected]] On Behalf Of Stephan Ewen Sent: Monday, March 07, 2016 8:29 PM To: [email protected] Subject: Re: realtion between operator and task Hi! A "task" is something that is deployed as one unit to the TaskManager and runs in one thread. A task can have multiple "operators" chained together, usually one per user function, for example "Map -> Filter -> FlatMap -> AssignTimestamps -> ..." Stephan On Mon, Mar 7, 2016 at 7:36 PM, Radu Tudoran <[email protected]<mailto:[email protected]>> wrote: 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.
