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