比如下面这种消息：
第一条消息：
{"source":"transaction_2020202020200","data":[{"ip":"127.0.0.1"}]}
第二条消息：
{"source":"transaction_2020202020200","data":[{"name":"d1111"},{"age":18}]}
第三条消息：
{"source":"transaction_2020202020200","data":[]}
我想直接在创建表时用一个字段来表示data这个属性的所有值。在 2020-12-09 13:21:41，"Appleyuchi" <[email protected]> 写道： >怎么个动态法? > > > > > >在 2020-12-09 13:18:56，"破极" <[email protected]> 写道： >>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... >> >> >>
