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

看日志

用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)

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

使用 convertRowToJSON 转一下

使用convertRowToJSON函数进行转换

convertRowToJSON

json

convertRowToJSON 就行  基础不行啊

用convertRowToJson方法转化

convertRowToJSON

convertRowToJSON

convertRowToJSON试一下

json

convertRowToJSON

convertRowToJSON

convertRowToJSON

convertRowToJSON

convertRowToJSON

用convertRowToJSON

用convertRowToJSON实现