火花提供了一种简便的方法来生成一个模式从一个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