You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "Mr.S" <19...@qq.com.INVALID> on 2021/12/28 07:28:55 UTC
回复：flinksql 使用collect聚合之后的值类型为Multiset，自定义java udf的时候，这个传入参数类型如何定义
hello ,多有打扰，找到官网一个函数可解决问题 listagg,谢谢各位
------------------ 原始邮件 ------------------
发件人: "Mr.S" <1986194217@qq.com>;
发送时间: 2021年12月28日(星期二) 下午3:12
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: flinksql 使用collect聚合之后的值类型为Multiset，自定义java udf的时候，这个传入参数类型如何定义
hello，我有一个sql需求，需要将collect聚合之后的值转为json数组，自定义java udf不知传入参数java数据类型改如何定义？
collect聚合之后的值{14004=1, 14009=1, 11004=1, 14007=1} 经过udf之后===> [14004,14009,11004,14007]