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

麻烦问下rowdata怎么转成string或者json

麻烦问下rowdata怎么转成string或者jsonimage.png

展开
收起
雪哥哥 2022-11-14 22:19:53 2628 1
35 条回答
写回答
取消 提交回答
  • 看日志

    2022-12-05 12:02:07
    赞同 展开评论 打赏
  • 用convertRowToJson函数可以转换,

    import scala.util.parsing.json.JSONObject import org.apache.spark.sql._

    val df = Seq((1,2,3),(2,3,4)).toDF("A", "B", "C")
    val row = df.first() // row 数据

    def convertRowToJSON(row: Row): String = { val m = row.getValuesMap(row.schema.fieldNames) JSONObject(m).toString() }

    convertRowToJSON(row)

    2022-11-29 19:44:55
    赞同 1 展开评论 打赏
  • 聊天室在线技术交流(摸鱼)http://chat.dilicili.cn
    def convertRowToJSON(row: Row): String = {
          var m: Map[String, String] = row.getValuesMap(row.schema.fieldNames)
          m = m.map(v => {
            if (v._2 == null) (v._1, "null") else v
          })
          JSONObject(m).toString()
        }
    
    

    需要注意的是map的value为空的情况 x

    2022-11-29 09:33:18
    赞同 展开评论 打赏
  • 使用 convertRowToJSON 转一下

    2022-11-29 07:55:09
    赞同 1 展开评论 打赏
  • 柳暗花明又一村

    使用convertRowToJSON函数进行转换

    2022-11-28 11:11:05
    赞同 展开评论 打赏
  • convertRowToJSON

    2022-11-26 21:03:13
    赞同 展开评论 打赏
  • json

    2022-11-26 19:50:47
    赞同 展开评论 打赏
  • 开源中国GVP

    convertRowToJSON 就行  基础不行啊

    2022-11-26 16:19:10
    赞同 展开评论 打赏
  • 用convertRowToJson方法转化

    2022-11-26 14:45:10
    赞同 展开评论 打赏
  • convertRowToJSON

    2022-11-26 13:23:39
    赞同 展开评论 打赏
  • convertRowToJSON

    2022-11-26 13:23:39
    赞同 展开评论 打赏
  • convertRowToJSON试一下

    2022-11-26 13:17:27
    赞同 展开评论 打赏
  • json

    2022-11-26 12:41:05
    赞同 展开评论 打赏
  • convertRowToJSON

    2022-11-26 11:31:36
    赞同 展开评论 打赏
  • 2020全国Datathon数据分析大赛亚军, 2021全国Datathon数据分析大赛亚军, 微软X英特尔黑客松全国总决赛10强, 亚马孙云科技线上黑客松全国总决赛10强

    convertRowToJSON

    2022-11-26 11:31:36
    赞同 展开评论 打赏
  • convertRowToJSON

    2022-11-26 11:31:36
    赞同 展开评论 打赏
  • convertRowToJSON

    2022-11-26 11:23:31
    赞同 展开评论 打赏
  • convertRowToJSON

    2022-11-26 11:23:32
    赞同 展开评论 打赏
  • 用convertRowToJSON

    2022-11-26 11:23:32
    赞同 展开评论 打赏
  • 用convertRowToJSON实现

    2022-11-26 11:22:28
    赞同 展开评论 打赏
滑动查看更多

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

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载

相关实验场景

更多