apache-spark - 为什么 insertInto 失败并显示 "assertion failed: No plan for InsertIntoTable"？

Question

我正在使用 SparkSql 进行查询。我正在尝试类似的事情:

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")

但出现错误

"java.lang.AssertionError: assertion failed: No plan for InsertIntoTable Map(), false"

似乎我使用 insertInto 的方式错误？

Answer 1

我也遇到了正常 SchemaRDD 的错误。当我尝试使用 Parquet 文件支持的 SchemaRDD 进行 insertInto 时，它成功了。 insertInto 方法看起来只支持 Parquet 支持的表。

1.1.0 API documentation on SQLContext告诉 Parquet 文件中的表可用于 insertInto 操作。 > “这个注册的表可以作为以后insertInto操作的目标。”