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
- Apache Flink - Question about TriggerResult.FIRE M Singh
- Re: Apache Flink - Question about TriggerResult.FIRE M Singh
- Re: Apache Flink - Question about TriggerResult.FIRE Stefan Richter
- Re: Apache Flink - Question about TriggerResult.... Aljoscha Krettek
- Re: Apache Flink - Question about TriggerRes... M Singh
- Re: Apache Flink - Question about Trigge... M Singh
- Re: Apache Flink - Question about T... Stefan Richter
- Re: Apache Flink - Question abo... Aljoscha Krettek
- Re: Apache Flink - Question abo... M Singh
- Re: Apache Flink - Question... Aljoscha Krettek
- Re: Apache Flink - Question... M Singh