Value toDF不是org.apache.spark.rdd.RDD[Any]的成员

import org.apache.spark.sql.{SparkSession, Row}
import org.apache.spark.sql.types._

val spark = SparkSession.builder()
  .appName("RDD to DataFrame")
  .master("local")
  .getOrCreate()

val rdd = spark.sparkContext.parallelize(Seq(("Alice", 25), ("Bob", 30), ("Charlie", 35)))

val schema = StructType(Seq(
  StructField("name", StringType, nullable = false),
  StructField("age", IntegerType, nullable = false)
))

val rowRDD = rdd.map{ case (name, age) => Row(name, age) }

val df = spark.createDataFrame(rowRDD, schema)
df.show()