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.rich...@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.swapni...@gmail.com > >: > > > > Can I get any update please ? > > > > Regards, > > Swapnil > >
