Hi, 你可以试下设置 event time 窗口为一天,然后设置 processing time timer 来定时每 5 分钟触发输出当天最新的结果。
Best, Paul Lam > 在 2019年3月5日,13:16,张作峰 <[email protected]> 写道: > > 大家好! > 请教下诸位大牛,如何使用stream api每五分钟统计一次当天某个消息的总条数? > 谢谢!
Hi, 你可以试下设置 event time 窗口为一天,然后设置 processing time timer 来定时每 5 分钟触发输出当天最新的结果。
Best, Paul Lam > 在 2019年3月5日,13:16,张作峰 <[email protected]> 写道: > > 大家好! > 请教下诸位大牛,如何使用stream api每五分钟统计一次当天某个消息的总条数? > 谢谢!