json作为csv一个列 flink ddl可以直接把json内字段解析出来吗? eg: name1,18,{'k1':'v1'}
json_value(json_column, '$.k1' ) ,此回答整理自钉群“【③群】Apache Flink China社区”
是的,Flink DDL可以直接将JSON字段解析为CSV格式。你可以使用CAST
函数将JSON字符串转换为JSON对象,然后使用JSON_EXTRACT
函数提取所需的字段。以下是一个示例:
SELECT
name1,
18,
CAST(JSON_EXTRACT(json_column, '$.k1') AS STRING) AS k1_value
FROM your_table;
在这个示例中,我们假设你的表名为your_table
,JSON列名为json_column
。我们将JSON字段中的k1
值提取出来,并将其作为新的列k1_value
添加到结果集中。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。