Re: Emulate Tumbling window in Event Time Space

2018-03-09 Thread Piotr Nowojski
> On 9 Mar 2018, at 1:51 PM, Dhruv Kumar <gargdhru...@gmail.com >> <mailto:gargdhru...@gmail.com>> wrote: >> >> Hi >> >> I was trying to emulate tumbling window in event time space. Here >> <https://github.com/kudhru/flink-learning/blob/mast

Re: Emulate Tumbling window in Event Time Space

2018-03-08 Thread Xingcan Cui
/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 tu

Emulate Tumbling window in Event Time Space

2018-03-08 Thread Dhruv Kumar
Hi I was trying to emulate tumbling window in event time space. Here 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