Hello,

       实际上,我也并不太关心这个字段的内容,能按string 保存下来就好了。

Best wishes.

Peihui He <[email protected]> 于2020年7月10日周五 上午10:12写道:

> Hello,
>
>        明白您的意思。但是当一个字段下的json 字段不确定,类似一个黑盒子一样的化,就不好定义了。
>
>
> Best wishes.
>
> LakeShen <[email protected]> 于2020年7月10日周五 上午10:03写道:
>
>> Hi Peihui,
>>
>> 如果消费的 Kafka json 中,json 比较复杂的话,比如存在嵌套,就像下面的格式:
>>
>> {
>>     "a":"b",
>>     "c":{
>>         "d":"e",
>>         "g":"f"
>>     }
>> },
>>
>> 那么在 kafka table source 可以使用 row 来定义:
>>
>> create table xxx (
>> a varchar,
>> c row<d varchar , g varchar>
>> )
>>
>> 如果 还存在嵌套,可以继续再使用 Row 来定义。
>>
>> Best,
>> LakeShen
>>
>> Peihui He <[email protected]> 于2020年7月10日周五 上午9:12写道:
>>
>> > Hello:
>> >
>> >         在用flink sql从kafka消费数据时,有些json比较复杂,想直接定义为object,在后续通过udf转为string。
>> >
>> >          有什么办法不?我在建表的时候有提示过json_object 类型,但是用了又提示其他类型。
>> >
>> >
>> > Best wishes.
>> >
>>
>

回复