Hello Fabian, Thanks for going through my long mail and concise responses. I am just happy that I was not way off the mark in my understanding.
It seems to me that I would rather wait for your blog before asking more questions. Not sure, if I will left with enough drive to write my (planned) blogs, once yours is out. :-) Yes, your solution works and as luck would have it, I figured out the same during the weekend, after going through your earlier responses. Thanks. One question though: You mentioned - ' It depends on the TriggerResult, what happens with the four elements after the user function was invoked. A CountTrigger keeps the elements in the window. ' Could you elaborate this point a bit? If CountTrigger _keeps_ the elements in the window, who _removes_ them? Are the elements removed by the Trigger's FIRE_AND_PURGE directive *or* by Flink runtime, when the current pane is destroyed by the runtime before a new pane is created? -- Nirmalya - Software Technologist http://www.linkedin.com/in/nirmalyasengupta "If you have built castles in the air, your work need not be lost. That is where they should be. Now put the foundation under them."
