Hi Dhruv, there’s no need to implement the window logic with the low-level `ProcessFunction` yourself. Flink has provided built-in window operators and you just need to implement the `WindowFunction` for that [1].
Best, Xingcan [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/windows.html#window-functions <https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/windows.html#window-functions> > On 9 Mar 2018, at 1:51 PM, Dhruv Kumar <gargdhru...@gmail.com> wrote: > > Hi > > I was trying to emulate tumbling window in event time space. Here > <https://github.com/kudhru/flink-learning/blob/master/TumblingWindowEmulationShare.java> > is the link to my code. > I am using the process function to do the custom processing which I want to > do within every window. I am having an issue of how to emit results at the > end of every window since my watermark only gets emitted at every incoming > event (incoming event will mostly not intersect with the end time of any > window). Seems like I need to add a trigger somewhere which fires at the end > of every window. Could any one here help me? Sorry, if I am not clear in > anything. I am quite new to Flink. > > Thanks > Dhruv
