Hi I have a linear streaming flow with a single source and multiple sinks to publish intermediate results. The time characteristic is Event Time and I am adding one AssignerWithPeriodicWatermarks immediately after the source. I need to add a different assigner, in the middle of the flow, to change the event time - i.e. extracting a different field from the record as event time.
I am not sure I completely understand the implications of changing event time and watermark in the middle of a flow. Can anybody give me a hint or direct me to any relevant documentation? Lorenzo
