My use case primarily concerns applying transformations per key, with the keys remaining fixed throughout the topology. I am using event time for my windows.
The problem i am currently facing is that watermarks in windows propagate per operator instance, meaning the operator event time increases for all keys that the operator is in charge of. I wish for watermarks to progress per key, not per operator instance. Is this easily possible? I was unable to find an appropriate solution based on existing code recipes. Greetings Leon
