scala - Spark 1.3.0 的 API 中 SchemaRDD 的声明在哪里

Question

1. 这些代码在IDEA中报错，为什么？

   val sqlContext = new org.apache.spark.sql.SQLContext(sc)
   import sqlContext.createSchemaRDD
   val people = sc.textFile("c3/test.txt").map(_.split(",")).map(p => Person(p(0), p(1).trim.toInt))
   people.registerTempTable("people")
   

2. 除了import sqlContext.createSchemaRDD之外，还有其他方法可以将sqlContext转换为SchemaRDD吗？

   <

3. 我在spark api文档中找不到SchemaRDD类，为什么？

Answer 1

SchemaRDD 在 Apache Spark 1.3.0 中已重命名为 DataFrame。请参阅migration guide .