flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Rich Window Function - When does close(tear down) method executes ?
Date Fri, 23 Sep 2016 13:25:14 GMT
Hi Swapnil,
you can just have all your logic in the apply() method of your
WindowFunction. This is called once the window fires so any code that you
put at the end there will be executed effectively after each window firing.

Cheers,
Aljoscha

On Fri, 23 Sep 2016 at 10:51 Stefan Richter <s.richter@data-artisans.com>
wrote:

> Hi,
>
> from the documentation of close(), the method is only called once at the
> end of the lifecycle of a user function:
>
> „Tear-down method for the user code. It is called after the last call to
> the main working methods (e.g. map or join).“
>
> If you want to perform tasks whenever a window triggers, you should use a
> trigger for that.
>
> Best,
> Stefan
>
> > Am 23.09.2016 um 08:43 schrieb Swapnil Chougule <the.swapnil09@gmail.com
> >:
> >
> > Can I get any update please ?
> >
> > Regards,
> > Swapnil
>
>

Mime
View raw message