My question is: what is the gradually of a so-called Operator.
To be more specific, in the following example, we have the Operators like, addSource and map. I am wondering is shuffle and print also a some kind of Operator?
DataStream<String> stream = env.
// Stateful source (e.g. Kafka) with ID
.uid("source-id") // ID for the source operator
// Stateful mapper with ID
.uid("mapper-id") // ID for the mapper
// Stateless printing sink
.print(); // Auto-generated ID
Or, in the following example, how many Operator we have (that we can assign IDs to)? 3? KeyBy, window and aggregate?
Then, how many Operators (and which are they) do we have in the following example?
Chang Liu 刘畅