开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

有人知道flink sql支持JSON_VALUE函数吗?或者将字符串转成json的函数,官网内置函

有人知道flink sql支持JSON_VALUE函数吗?或者将字符串转成json的函数,官网内置函数好像没找到

展开
收起
圆葱猪肉包 2023-04-19 16:49:35 846 0
3 条回答
写回答
取消 提交回答
  • 公众号:网络技术联盟站,InfoQ签约作者,阿里云社区签约作者,华为云 云享专家,BOSS直聘 创作王者,腾讯课堂创作领航员,博客+论坛:https://www.wljslmz.cn,工程师导航:https://www.wljslmz.com

    Flink SQL 支持 JSON_VALUE 函数,可以通过如下方式来使用:

    SELECT JSON_VALUE(json_str, '$.key') FROM table_name;
    

    其中,json_str 为 JSON 字符串,'$.key' 表示要获取的 JSON 中的字段,table_name 为表名。

    同时,Flink SQL 也提供了将字符串转为 JSON 的函数 TO_JSON,可以使用该函数来将字符串转成 JSON:

    SELECT TO_JSON('{"key": "value"}') FROM table_name;
    

    该函数会返回一个 JSON 对象,可以进一步用其他函数来进行解析。

    2023-04-30 22:44:40
    赞同 展开评论 打赏
  • 1.12不支持,从1.14开始支持了,此回答整理自钉群“【③群】Apache Flink China社区”

    2023-04-19 22:42:55
    赞同 展开评论 打赏
  • 存在即是合理

    Flink SQL支持 JSON_VALUE 函数。JSON_VALUE 函数是 Flink SQL 中用于处理 JSON 数据的函数,它可以将 JSON 数据转换为 Flink SQL 中的 ROW 或 ROWS 类型,并执行相应的操作。参考:

    
    SELECT  
      JSON_VALUE('$.name', 'John') AS name,  
      JSON_VALUE('$.age', 30) AS age  
    FROM  
      my_table  
    WHERE  
      name = 'John'
    
    

    示例中,我们使用 JSON_VALUE 函数将 JSON 数据中的 name 和 age 属性转换为 Flink SQL 中的 ROW 类型,并将其作为 name 和 age 列返回。可以根据需要将 JSON_VALUE 函数应用于其他 Flink SQL 操作,例如聚合、过滤等,试试看吧

    2023-04-19 16:57:11
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    SQL Server在电子商务中的应用与实践 立即下载
    GeoMesa on Spark SQL 立即下载
    原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载