火花提供了一種簡便的方法來生成一個模式從一個Scala類。對於用例類一個、使用方法[一]ScalaReflection.schemaFor .dataType.asInstanceOf [StructType]。
例如:
% scala org.apache.spark.sql.types進口。StructType org.apache.spark.sql.catalyst進口。ScalaReflection case類(關鍵:字符串,時間:java.sql。時間戳,日期:java.sql。日期、小數:java.math。BigDecimal,地圖:地圖(字符串、整數),嵌套:Seq[地圖(字符串,Seq [Int]]]) val模式= ScalaReflection.schemaFor .dataType。asInstanceOf StructType schema.printTreeString