Hello,
I'm investigating switching our windowing to event time, and I figured it
would be good to assign timestamps/watermarks *after* the keyBy we need for
the windows. However, I see the keyBy method instantiates a
PartitionTransformation whose Javadoc states: "This does not create a
physical operation, it only affects how upstream operations are connected
to downstream operations."
So the question is, if I have a DataStream and I define the job like this:
var watermarked = stream.keyBy(...)
.assignTimestampsAndWatermarks(...)
DataStreamUtils.reinterpretAsKeyedStream(watermarked, ...)
.window(...)
Is this actually working as expected?
Regards,
Alexis.
