（1）示例數據：`people.json` ```json {"name":"Michael"} {"name":"Andy", "age":30} {"name":"Justin", "age":19} ``` （2）示例代碼 ```scala import org.apache.spark.SparkContext import org.apache.spark.rdd.RDD import org.apache.spark.sql.{DataFrame, Row, SparkSession} object DataFrameToRDD { def main(args: Array[String]): Unit = { val spark:SparkSession = SparkSession.builder() .master("local[4]") .appName(this.getClass.getName) .getOrCreate() val sc:SparkContext = spark.sparkContext import spark.implicits._ // 兩種方式加載json/csv文件, spark.read.format("json") 或者 spark.read.json 效果一樣 // 創建DataFrame val df:DataFrame = spark.read.json("file:///E:\\hadoop\\input\\people.json") val rdd:RDD[Row] = df.rdd // 只需調用rdd方法便可以將DataFrame轉換為RDD[Row] rdd.foreach(println) // [null,Michael] // [30,Andy] // [19,Justin] rdd.map(x => (x(0), x(1))).foreach(println) // (null,Michael) // (30,Andy) // (19,Justin) } } ```