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