flink sql是否有json_to_map函数，或者实现方法是怎么样的？

[Jeff]

hi all,


有没有什么办法可以将json转成map呢？类似于str_to_map函数。


版本：flink 1.11
planner: blink sql


需求背景： UDF函数通过http请求获得了json字符串，希望能够直接使用json内字段， UDTF可以满足一部分要求，但不灵活，因为定义UDTF时需要指定输出字段及类型，限制很大。

[Michael Ran]

特定的的map也是需要类型的，如果你在乎类型建议里面统一以字符串的udtf实现，后续再进行转换
在 2021-01-21 18:35:18，"Jeff" <[hidden email]> 写道：

>hi all,
>
>
>有没有什么办法可以将json转成map呢？类似于str_to_map函数。
>
>
>版本：flink 1.11
>planner: blink sql
>
>
>需求背景： UDF函数通过http请求获得了json字符串，希望能够直接使用json内字段， UDTF可以满足一部分要求，但不灵活，因为定义UDTF时需要指定输出字段及类型，限制很大。

[Jeff]

但udtf需要指定结果返回个数及字段名,如：@FunctionHint(output = @DataTypeHint("ROW<col1 STRING>")，但我希望把这个udtf弄得通用一点，因为json结构是不确定的，不受字段名跟字段个数限制。

















在 2021-01-21 18:02:06，"Michael Ran" <[hidden email]> 写道：

>特定的的map也是需要类型的，如果你在乎类型建议里面统一以字符串的udtf实现，后续再进行转换
>在 2021-01-21 18:35:18，"Jeff" <[hidden email]> 写道：
>>hi all,
>>
>>
>>有没有什么办法可以将json转成map呢？类似于str_to_map函数。
>>
>>
>>版本：flink 1.11
>>planner: blink sql
>>
>>
>>需求背景： UDF函数通过http请求获得了json字符串，希望能够直接使用json内字段， UDTF可以满足一部分要求，但不灵活，因为定义UDTF时需要指定输出字段及类型，限制很大。

[Jeff]

但udtf需要指定结果返回个数及字段名,如：@FunctionHint(output = @DataTypeHint("ROW<col1 STRING>")，但我希望把这个udtf弄得通用一点，因为json结构是不确定的，不受字段名跟字段个数限制。















在 2021-01-21 18:02:06，"Michael Ran" <[hidden email]> 写道：

>特定的的map也是需要类型的，如果你在乎类型建议里面统一以字符串的udtf实现，后续再进行转换
>在 2021-01-21 18:35:18，"Jeff" <[hidden email]> 写道：
>>hi all,
>>
>>
>>有没有什么办法可以将json转成map呢？类似于str_to_map函数。
>>
>>
>>版本：flink 1.11
>>planner: blink sql
>>
>>
>>需求背景： UDF函数通过http请求获得了json字符串，希望能够直接使用json内字段， UDTF可以满足一部分要求，但不灵活，因为定义UDTF时需要指定输出字段及类型，限制很大。