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

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

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

解决方案:

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