Hi Rock, Sorry, I don't fully understand what you want. If you want a tumbling window which covers one day, you can use `KeyedStream#timeWindow(Time.days(1))` which covers from UTC 00:00~24:00.
Best, Jark On Tue, 26 Nov 2019 at 17:20, Caizhi Weng <tsreape...@gmail.com> wrote: > Hi Rock, > > I think you can write your own trigger which fires when the date of the > process time of the current record is different from that of the last > record. > > Pinging @Jark Wu for a more professional answer. > > Rock <downsidem...@qq.com> 于2019年11月26日周二 下午3:37写道： > >> I need my job to aggregator every device's mertic as daily report.But I >> did not find a window can cover exactly one day,or let everyday's beginning >> as watermark .Should I custom a window or any other way to achieve? >> >
