Hi,

你可以试下设置 event time 窗口为一天,然后设置 processing time timer 来定时每 5 分钟触发输出当天最新的结果。

Best,
Paul Lam

> 在 2019年3月5日,13:16,张作峰 <[email protected]> 写道:
> 
> 大家好!
> 请教下诸位大牛,如何使用stream api每五分钟统计一次当天某个消息的总条数?
> 谢谢!

回复