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: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org