??????Flink sql count ??????????????

Wed, 26 Feb 2020 02:57:52 -0800 

??????????  
count(distinct ????????????)   ,  distinct  a,b ????????
????????????????count(distinct  concat(a,b))


| |
apache22
|
|
[email protected]
|
??????????????????????
??2020??2??26?? 18:21????????<[email protected]> ??????
??????:
&nbsp; &nbsp; &nbsp; &nbsp; 
????flink??????????????????????????count????????????????
&nbsp; &nbsp; &nbsp; &nbsp; count([all] Expression | distinct Expression1 [, 
Expression2])
&nbsp; &nbsp; &nbsp; &nbsp; 
????????????????????????????distinct??????????????????????????????????????????????
 select count(distinct a, b) from mytable??????????????????????
&nbsp; &nbsp; &nbsp; &nbsp; ????????????sql????????????????????&nbsp; 
codegenexpression. No matching accumulate methods for Aggregation function. 
......CountAggFunction with Parameters (Java.lang.String, java.lang.Long)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;Flink1.8??1.9????????????????????????????????

回复