但udtf需要指定结果返回个数及字段名,如:@FunctionHint(output = @DataTypeHint("ROW<col1 STRING>"),但我希望把这个udtf弄得通用一点,因为json结构是不确定的,不受字段名跟字段个数限制。
在 2021-01-21 18:02:06,"Michael Ran" <greemqq...@163.com> 写道: >特定的的map也是需要类型的,如果你在乎类型建议里面统一以字符串的udtf实现,后续再进行转换 >在 2021-01-21 18:35:18,"Jeff" <zilong0...@126.com> 写道: >>hi all, >> >> >>有没有什么办法可以将json转成map呢?类似于str_to_map函数。 >> >> >>版本:flink 1.11 >>planner: blink sql >> >> >>需求背景: UDF函数通过http请求获得了json字符串,希望能够直接使用json内字段, >>UDTF可以满足一部分要求,但不灵活,因为定义UDTF时需要指定输出字段及类型,限制很大。