如何在Spark 2 Scala中将Row转换为json

import org.apache.spark.sql.{Row, SparkSession}
import org.json4s.jackson.JsonMethods._
import org.json4s.DefaultFormats

object RowToJson {
  def main(args: Array[String]): Unit = {
    // 创建SparkSession
    val spark = SparkSession.builder()
      .appName("Row to JSON")
      .master("local")
      .getOrCreate()

    // 创建Row对象
    val row = Row("John", 30, "john@example.com")

    // 将Row转换为JSON
    val json = rowToJson(row)

    // 打印JSON字符串
    println(json)

    // 关闭SparkSession
    spark.stop()
  }

  def rowToJson(row: Row): String = {
    // 创建一个包含Row字段名的列表
    val fieldNames = row.schema.fieldNames

    // 创建一个包含Row字段值的列表
    val fieldValues = row.toSeq.toList

    // 将字段名和字段值组合成键值对
    val keyValuePairs = fieldNames.zip(fieldValues)

    // 将键值对转换为JSON字符串
    implicit val formats = DefaultFormats
    val json = compact(render(keyValuePairs.toMap))

    json
  }
}

libraryDependencies += "org.apache.spark" %% "spark-sql" % "2.4.8"
libraryDependencies += "org.json4s" %% "json4s-jackson" % "3.7.0-M5"