scala – Spark SQL：来自csv的自动模式

目前我将加载一个csv文件,如下所示：

case class Record(id: String,val1: String,val2: String,....)

 sc.textFile("Data.csv")
.map(_.split(",")) 
.map { r =>                  
   Record(r(0),r(1),.....)
}.registerAsTable("table1")

有关csv文件自动模式扣除的任何提示吗？特别是a)我如何生成一个代表模式的类,以及b)如何自动填充它(即Record(r(0),…..))？

更新：
我在这里找到了对模式生成的部分答案：
http://spark.apache.org/docs/1.1.0/sql-programming-guide.html#data-sources

// The schema is encoded in a string
val schemaString = "name age"
// Generate the schema based on the string of schema
val schema =
 StructType(
schemaString.split(" ").map(fieldName => StructField(fieldName,StringType,true)))
// Convert records of the RDD (people) to Rows.
val rowRDD = people.map(_.split(",")).map(p => Row(p(0),p(1).trim))
// Apply the schema to the RDD.
val peopleSchemaRDD = sqlContext.applySchema(rowRDD,schema)

所以剩下的唯一问题就是如何做到这一步
??map(p => Row(p(0),p(1).trim))动态地给定给定数量的属性？

感谢您的支持！
约尔格