但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时需要指定输出字段及类型,限制很大。

Reply via email to