Re:Flink SQL读取复杂JSON格式

[Appleyuchi]

怎么个动态法?





在 2020-12-09 13:18:56，"破极" <zapj...@163.com> 写道：
>Hello，各位大佬：
>请教下大佬们，在Flink 
>SQL中读取Kafka中的数据，但Kafka中的数据比较复杂，其中json的data属性中的值是数组，但数组的内容是动态的，没有统一，如果定义create 
>table时候schema呢？我定义了array<string>，想自己定义UDF来处理的，在JsonNode中的asText无法取到数据。
>请问各位大佬有啥高招呢？谢谢。
>
>
>kafka消息样例(data的value是动态的)：
>{"source":"transaction_2020202020200","data":[{"name":"d1111"},{"age":18}]}
>我定义的schema：
>create table kafka_message(
> source string,
>data array<string>
>)with...
>
>
>