t; }
> > >
> > > However the open() method is not invoked when i try to run this code
> on my
> > > local environment
> > >
> > >spx
> > > .groupBy(x => x.symbol)
> > > .window(Time.of(5, TimeUnit.SECONDS)).every(T
i try to run this code on my
> > local environment
> >
> >spx
> > .groupBy(x => x.symbol)
> > .window(Time.of(5, TimeUnit.SECONDS)).every(Time.of(1,
> > TimeUnit.SECONDS))
> > .mapWindow(new MyWindowFunction)
> >
> > Any tho
gt; >
> > However the open() method is not invoked when i try to run this code on
> my
> > local environment
> >
> >spx
> > .groupBy(x => x.symbol)
> > .window(Time.of(5, TimeUnit.SECONDS)).every(Time.of(1,
> > TimeUnit.SECONDS))
> &g
ion)
>
> Any thought on this one ?
>
>
> Cheers
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Open-method-is-not-called-with-custom-implementation-RichWindowMapFunction-tp1924.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at
> Nabble.com.
n4.nabble.com/Open-method-is-not-called-with-custom-implementation-RichWindowMapFunction-tp1924.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
