Hi,
timestamps and watermarks are attached to every stream record in the
runtime. After assignTimestampsAndWatermarks() extracted them, Flink
handles those attributes internally.
For example, it doesn't matter which class you are emitting in a flatMap
function, the runtime will set the times
In KeyedProcessFunction, we can register a timer based on EventTime, but in
the register method, we don't need to specify the time column. So if the
elements of this KeyedStream are not the classes that originally specified
timestamp and watermark, can this timer run normally?
