flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nirmalya Sengupta <sengupta.nirma...@gmail.com>
Subject Re: Continuing from the stackoverflow post
Date Mon, 30 Nov 2015 17:59:32 GMT
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
"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."

View raw message