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.
>
