Hi Flink Users
I have a few questions about triggers:
If a trigger returns TriggerResult.FIRE from say the onProcessingTime method - 
the window computation is triggered but elements are kept in the window.  If 
there a second invocation of the onProcessingTime method will the elements from 
the previous window (which were not purged) a part of the new window 
computation along with new events added since the last FIRE event ? 
Secondly, how does the FIRE option affect the sliding window computation ?
If there are any other insights/pitfalls while dealing with this, please let me 
know.
Thanks
Mans

Reply via email to