Hi, this looks almost correct. In your written description you say that the Trigger should fire after the allowed lateness if a signal event was received. In your code, however, you fire at the timestamp of the signal event.
Best, Aljoscha > On 3. Apr 2017, at 18:45, nragon <nuno.goncal...@wedotechnologies.com> wrote: > > 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.
