Windowing and triggering on a keyed stream is done independently for each
key. So for each key, your custom trigger is observing when the lunumState
changes from null to a production cycle number, but it will never change
again -- because only those stream elements with the same key will be
process
Hello people!
I have a DataStream, which has events with with a continuing number
which signifies their belonging to a production cycle. In essence, this
is what the data looks like:
value, production cycle
12.0, 2000
12.3, 2000 one production cylce
12.2, 2000
0.0, 2001
0.4, 2002 another pro
