Hi Nirmalya,
event time events (such as an event time trigger to compute a window) are
triggered when a watermark is received that is larger than the triggers
timestamp. By default, watermarks are emitted with a fixed time interval,
i.e., every x milliseconds. When a new watermark is emitted, Flin
Hello Fabian
Merry Christmas to you and everyone else in this forum.
Another neophyte's question, patience please.
I have following code:
val env = StreamExecutionEnvironment.createLocalEnvironment(1)
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
val readings =
