1:51 PM, Dhruv Kumar > <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/master/TumblingWindowEmulationShare.java>
>> is the l
/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 wrote:
>
> Hi
>
> I was trying to emulate tumbling window in event time
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
