I'm using SparkSql for querying. I'm trying something like:
val sqc = new SQLContext(sc);
import sqc.createSchemaRDD
var p1 = Person("Hari",22)
val rdd1 = sc.parallelize(Array(p1))
rdd1.registerAsTable("data")
var p2 = Person("sagar", 22)
var rdd2 = sc.parallelize(Array(p2))
rdd2.insertInto("data")
but getting the error
"java.lang.AssertionError: assertion failed: No plan for InsertIntoTable
Map(), false"
Seems I'm using the insertInto the wrong way?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-SQL-insertInto-tp12810.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
