flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nragon <nuno.goncal...@wedotechnologies.com>
Subject Signal Trigger
Date Mon, 03 Apr 2017 16:45:05 GMT
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.

Mime
View raw message