Re: 如何每五分钟统计一次当天某个消息的总条数

[王涛]

这倒也是个方法，每五分钟触发一次window function，每次触发时windows的状态都会被保存下来，所以不会丢失数据。
但是，如果你是用的eventTime，那你的这个五分钟的概念就是eventTime概念的五分钟，不是ProcessTime了，这也会导致数据流暂停时最后的消息有可能无法输出了。