It is evident that if I have n windows and subsequent aggregate, on a keyed stream, it is a n way hash increasing as in n copies of the stream. Is there a reason why that is the direction flink has gone rather than one hash operator localized specific window/subsequent operations.