Flink window+trigger 怎么区别不同的数据输出

问题需求： 我们在日常的需求中，通常会汇总计算，比如一天的数据总数 ，然后每分钟要输出一次结果  1）window+trigger实现，就是下面的代码，缺点是没办法区分哪个输出结果是汇总结果，可以参考下面的代码，把窗口的end时间做一个state存储，然后判断大小，再输出最后的汇总值 DataStream<String> aggregateStream = nextStream //

>>阅读原文<<