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 <peihu...@gmail.com> 于2020年7月10日周五 上午9:12写道:

> Hello:
>
>         在用flink sql从kafka消费数据时,有些json比较复杂,想直接定义为object,在后续通过udf转为string。
>
>          有什么办法不?我在建表的时候有提示过json_object 类型,但是用了又提示其他类型。
>
>
> Best wishes.
>

回复