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
添加到结果集中。
本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/13656.html