场景:
flink 三个 tuple2(key,value)的流 union 之后 map到 对象中 根据key set到不同字段,方便之后输出到kafka
三个流已经做过按天聚合
问题:
虽然可以合并输出 但是无法做到跨天清零 如何让数据跨天清零呢?
场景:
flink 三个 tuple2(key,value)的流 union 之后 map到 对象中 根据key set到不同字段,方便之后输出到kafka
三个流已经做过按天聚合
问题:
虽然可以合并输出 但是无法做到跨天清零 如何让数据跨天清零呢?
解决方案: