Spark提供了一種從Scala案例類生成模式的簡單方法。對於用例類一個,使用方法[一]ScalaReflection.schemaFor .dataType.asInstanceOf [StructType].
例如:
%scala import org.apache.spark.sql.types.StructType import org.apache.spark.sql.catalyst.ScalaReflection case class A(鍵:字符串,時間:java.sql. sql.type)時間戳,日期:java.sql。日期、小數:java.math。BigDecimal, map: map [String, Int], nested: Seq[map [String, Seq[Int]]) val schema = ScalaReflection.schemaFor[A]. datatype。asInstanceOf StructType schema.printTreeString