需要,针对某个表,按照key1(xxx+yyy+ky1),key2(xxx+yyy+ky2),....等多组key统计。其中xxx+yyy为共同字段。目前有如下3种实现我。 (1)每组key分别统计,分别insert。 (2)每组key分别统计,然后union结果,然后insert。 (3)针对表多次select,然后union,然后再基于key统计,然后insert。 第三种方案中,会将ky1、ky2这几个不同的字段通过
select 'ky1' as key_name, ky1 as key_value union select 'ky2' as key_name, ky2 as key_value 的方式统一为key这个字段,最后通过(xxx+yyy+key_name+key_value)的方式统计。 目前发现个问题,方案3中,window结点一直没有watermark,导致不发生计算。
