Hi Stephan, My use case is the following: Every time an event is processed with a signal event the window must be fired after the allowed lateness. If no signal event arrives the window must close after the gap, like in session window. I’m registering a timer for signal + allowed lateness. Hope you can tell me if you think this is a good idea :) EventTimeSessionSignalTrigger.java <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n12509/EventTimeSessionSignalTrigger.java> SignalReduceFunction.java <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n12509/SignalReduceFunction.java>
Thanks, Nuno -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Signal-Trigger-tp12509.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
