Re: Interpretation of Trigger and Eviction on a window

2015-11-30 Thread Fabian Hueske
Yes, that is correct. The first element will be lost. In fact, you do neither need a trigger nor an evictor if you want to get the max element for each group of 5 elements. See my reply on your other mail. Cheers, Fabian 2015-11-30 18:47 GMT+01:00 Nirmalya Sengupta : > Hello Aljoscha , > > Many

Re: Interpretation of Trigger and Eviction on a window

2015-11-30 Thread Nirmalya Sengupta
Hello Aljoscha , Many thanks for taking time to explain the behaviour of Evictor. The essence of my original post - about how the guide explains an Evictor - was this. I think the guide should make this (counterintuitive) explanation of the parameter to Evictor clearer. May help others, yet uninit

Re: Interpretation of Trigger and Eviction on a window

2015-11-30 Thread Aljoscha Krettek
Hi, the Evictor is very tricky to understand, I’m afraid. What happens when a Trigger fires is the following: 1. Trigger fires 2. Evictor can remove elements from the window buffer 3. Window function processes the elements that remain in the window buffer The tricky thing here is that the Evic

Re: Interpretation of Trigger and Eviction on a window

2015-11-30 Thread Nirmalya Sengupta
Hi Aljoscha , Thanks for taking interest in my post and question. If the Evictor removes elements _before_ the function is applied, then what happens the first time, the Evictor is acting? That's what I am failing to understand. At the beginning of the operation on the Stream, he Trigger finds

Re: Interpretation of Trigger and Eviction on a window

2015-11-30 Thread Aljoscha Krettek
Hi, the function is in fact applied to the remaining elements (at least I hope it is). So the first sentence should be the correct one. Cheers, Aljoscha > On 28 Nov 2015, at 03:14, Nirmalya Sengupta > wrote: > > Hello Fabian, > > From your reply to this thread: > ' it is correct that the evi

Re: Interpretation of Trigger and Eviction on a window

2015-11-27 Thread Nirmalya Sengupta
Hello Fabian, >From your reply to this thread: ' it is correct that the evictor is called BEFORE the window function is applied because this is required to support certain types of sliding windows. ' This is clear to me now. However, my point was about the way it is described in the User-guide. T

Re: Interpretation of Trigger and Eviction on a window

2015-11-27 Thread Fabian Hueske
Hi Nirmalya, it is correct that the evictor is called BEFORE the window function is applied because this is required to support certain types of sliding windows. If you want to remove all elements from the window after the window function was applied, you need a trigger that purges the window. The

Interpretation of Trigger and Eviction on a window

2015-11-27 Thread Nirmalya Sengupta
Hello there. I have just started exploring Apache Flink, and it has immediately got me excited. Because I am a beginner, my questions may be a bit naive. Please bear with me. I refer to this particular sentence from Flink 0.10.0 Guide