Re: Adding proctime columng to table api

2021-02-17 Thread Rex Fenley
Following from that, I'm not really sure why I need to provide a proctime timestamp. There should never be any late data with proctime, when a record arrives it should just be put into whatever the current window is. So why is there any requirement to specify a time column in this case? Thanks! O

Re: Adding proctime columng to table api

2021-02-17 Thread Rex Fenley
Also, as an example, I've tried table.window(Tumble over 1.seconds on proctime() as $"w")... and it failed. On Wed, Feb 17, 2021 at 9:30 PM Rex Fenley wrote: > Hi, > > When using streaming api, if I want a tumbling window on proctime all I > have to do is the following: > table.window(TumblingPr