Generieren ein Funke StructType/Schema aus einer Fallklasse

Question

Wenn ich ein StructType (das heißt ein DataFrame.schema) aus einem case class schaffen wollte, ist es eine Möglichkeit, es zu tun, ohne ein DataFrame zu schaffen? Ich kann leicht tun:

case class TestCase(id: Long) 
val schema = Seq[TestCase]().toDF.schema 

Aber es scheint übertrieben, tatsächlich ein DataFrame zu erstellen, wenn alles, was ich möchte das Schema.

(Wenn Sie neugierig sind, ist der Grund für die Frage, dass ich eine UserDefinedAggregateFunction bin definieren, und Sie so außer Kraft setzen ein paar Methoden zu tun, die StructTypes und ich verwende Fallklassen zurück.)

Answer 1

Sie tun können es ist die gleiche Art und Weise SQLContext.createDataFrame tut es:

import org.apache.spark.sql.catalyst.ScalaReflection 
val schema = ScalaReflection.schemaFor[TestCase].dataType.asInstanceOf[StructType] 

Answer 2

ich weiß, diese Frage fast ein Jahr alt ist, aber ich kam über sie und dachte, andere, die auch wissen, tun möchten vielleicht, dass ich gerade diesen Ansatz verwenden gelernt:

import org.apache.spark.sql.Encoders 
val mySchema = Encoders.product[MyCaseClass].schema 

Answer 3

falls jemand möchte dies für eine benutzerdefinierte Java Bean tun:

ExpressionEncoder.javaBean(Event.class).schema().json()