Re: Question on window ProcessFunction

to the newer implementation. > > Best, > Aljoscha > > On 26. Apr 2017, at 14:51, 魏偉哲 wrote: > > > > Hi Aljoscha, > > > > I know the aggregate code is newer. I am confused because the > > implementations are not consistent. > > Does it mean that the red

Re: Question on window ProcessFunction

) instead of > InteralAggregateFunction(Aggregate). > > Best, > Aljoscha > > On 26. Apr 2017, at 06:39, 魏偉哲 wrote: > > > > Hi all, > > > > Recently, I was tracing the source code in streaming api and I was > confused > > about some implementations. > >

Question on window ProcessFunction

Hi all, Recently, I was tracing the source code in streaming api and I was confused about some implementations. When using reduce function with evictor, the *WindowStream* will wrap the *ReduceFunction* and *ProcessWindowFunction* into *ReduceApplyProcessWindonwFunction* and put it in *InternalIt

JIRA task Assignment

Hi I would like to wok on https://issues.apache.org/jira/browse/FLINK-4611. Can someone assign the task to me? My ID is "tonywei".