flink 合流到对象无法跨天清零？

Question

场景：
flink 三个 tuple2（key，value）的流 union 之后 map到 对象中 根据key set到不同字段,方便之后输出到kafka
三个流已经做过按天聚合

问题：
虽然可以合并输出 但是无法做到跨天清零 如何让数据跨天清零呢？

Answer 1

解决方案：

1. 在每个流中使用window函数，将每天的数据按天分窗口，在每天的每个窗口结束时，发出一个信号，用于清零；
2. 在union之后，使用keyBy函数，将数据按照key分组，然后使用timeWindow函数，将每天的数据按天分窗口，在每天的每个窗口结束时，发出一个信号，用于清零。