Hi Guys
Is there any insight into this ?
Thanks
Mans
On Monday, November 13, 2017 11:19 AM, M Singh <mans2si...@yahoo.com> wrote:
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
