Re: question on sideoutput from ProcessWindow function

2017-09-23 Thread Chen Qin
Be lated update. actually @phoenixjiangnan is already working on this ​https://issues.apache.org/jira/browse/FLINK-7635 On Sat, Sep 23, 2017 at 8:26 AM, Ufuk Celebi wrote: > +1 > > Created an issue here: https://issues.apache.org/jira/browse/FLINK-7677 > > > On Thu, Sep 14,

Re: question on sideoutput from ProcessWindow function

2017-09-23 Thread Ufuk Celebi
+1 Created an issue here: https://issues.apache.org/jira/browse/FLINK-7677 On Thu, Sep 14, 2017 at 11:51 AM, Aljoscha Krettek wrote: > Hi, > > Chen is correct! I think it would be nice, though, to also add that > functionality for ProcessWindowFunction and I think this

Re: question on sideoutput from ProcessWindow function

2017-09-14 Thread Aljoscha Krettek
Hi, Chen is correct! I think it would be nice, though, to also add that functionality for ProcessWindowFunction and I think this should be easy to do since the interface is very similar to ProcessFunction and we could also add that to the Context. Best, Aljoscha > On 9. Sep 2017, at 06:22,

Re: question on sideoutput from ProcessWindow function

2017-09-08 Thread Chen Qin
Hi Prabhu, That is good question, the short answer is not yet, only ProcessFunction was given flexibility of doing customized sideoutput at the moment. Window Function wasn't given such flexibility partially due to sideoutput initially targeting late arriving event for window use cases.

question on sideoutput from ProcessWindow function

2017-09-08 Thread Prabhu V
Hi, Can we have a side output from a process window function ? I am currently genrating a side output from a process function. The main output of the process function is then Windowed and a ProcessWindowFunction is applied on the windows. Can I add to the SideOutpuStream from the