??????flink-1.12.0(1.13.2????????????) select datas[1].filed_1,datas[1].filed_2????????????????????

[kcz]

soryy ??????????????????????????????????????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "kcz"                            
                                                        <573693...@qq.com&gt;;
????????:&nbsp;2021??9??26??(??????) ????10:53
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;flink-1.12.0(1.13.2????????????) select 
datas[1].filed_1,datas[1].filed_2????????????????????



??????????INDEX??????????????????????INDEX++ 
??????????value????????????????????????????array????????????????????????????????????????????????
CREATE TABLE KafkaTable (
&nbsp; datas array<row<filed_1 STRING,filed_2 INT&gt;&gt;
) WITH (
&nbsp; 'connector' = 'kafka',
&nbsp; 'topic' = 'user_behavior',
&nbsp; 'properties.bootstrap.servers' = 'localhost:9092',
&nbsp; 'properties.group.id' = 'testGroup',
&nbsp; 'scan.startup.mode' = 'earliest-offset',
&nbsp; 'format' = 'json'
);

SELECT datas ,datas [1].filed_1, datas [1].filed_2&nbsp; from KafkaTable;