You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by kcz <57...@qq.com.INVALID> on 2021/09/26 03:18:59 UTC
回复:flink-1.12.0(1.13.2也是这个问题) select datas[1].filed_1,datas[1].filed_2,除了第一个字段有值
soryy 大家,是我弄错了,逻辑是正确的,也可以取到值。
------------------ 原始邮件 ------------------
发件人: "kcz" <573693104@qq.com>;
发送时间: 2021年9月26日(星期天) 上午10:53
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: flink-1.12.0(1.13.2也是这个问题) select datas[1].filed_1,datas[1].filed_2,除了第一个字段有值
除了第一个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;