1. package com
    3. import org.apache.spark.sql.{DataFrame, SparkSession}
    5. case class User(name: String, age: Int)
    6. object DF2RDD {
    7.   def main(args: Array[String]): Unit = {
    8.     val spark: SparkSession = SparkSession
    9.       .builder()
    10.       .master("local[*]")
    11.       .appName("DF2RDD")
    12.       .getOrCreate()
    15.     val df = spark.read.json("E:\\ZJJ_SparkSQL\\demo01\\src\\main\\resources\\users.json")
    16.     df.printSchema()
    17.     val rdd1 = df.rdd.map(row => {
    18.       User(row.getString(1), row.getLong(0).toInt)
    19.     })
    20.     rdd1.collect.foreach(println)
    23.     spark.close()
    26.   }
    27. }

    输出

    1. User(张三,18)
    2. User(李四,15)