spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ionized <ioni...@gmail.com>
Subject Spark SQL registerAsTable requires a Java Class?
Date Tue, 08 Jul 2014 06:48:33 GMT
The Java API requires a Java Class to register as table.

// Apply a schema to an RDD of JavaBeans and register it as a
table.JavaSchemaRDD schemaPeople = sqlCtx.applySchema(people,
Person.class);schemaPeople.registerAsTable("people");

If instead of JavaRDD<Person> I had JavaRDD<List> (along with the knowledge
of column names and types that go along with the List) and wanted to write
a general-purpose registerAsTable, is there any other way besides using ASM
and dynamically creating Java Classes?

Mime
View raw message