Re:flink????????????????????

2021-12-02 文章 Michael Ran
jdbc scan ?? 2021-12-02 14:40:06??"" ?? >

flink sql怎样获取到Multiset类型的keys和values?

2021-12-02 文章 casel.chen
我通过flink sql的collect函数获取到Multiset类型,即Map类型,现在只想获取到所有的Kt集合,请问要怎么用flink sql表达?

Re:Re: flink sql collect函数使用问题

2021-12-02 文章 casel.chen
可我要的最终结果不是string,最好是通用的Row类型,这样的话下次聚合其他维度就不用重复开发UDF了。 类似我这样的需求应该其他人也会遇到吧? 功能:collect出一个Multiset即map,key是数据本身,value是数据出现的次数,可以按出现次数排序等。 输出可以是去重或不去重的Array(按出现次数排序或不排序),也可以就是map本身 目前collect函数可以输出一个Multiset即map,但要怎么按value即出现次数排序并只输出排序后的keyset,用flink sql要怎么写呢? 在 2021-12-02