更新查询schemaRDD

Question

我在斯卡拉使用schemaRDD一些数据转换。当使用更新查询就像这样的例子UPDATE users SET email = 'abc@example.com' WHERE ID = 1我收到以下错误SQL上下文：

java.lang.RuntimeException: [1.1] failure: ''UNCACHE'' expected but identifier UPDATE found

快速反应将高度赞赏。

一个SchemaRDD的

Answer 1

由于底层实现（数据结构）是一种RDD是不可变的，我不认为它支持一个UPDATE。如果您想更新的东西，一种方法是创建一个副本，做转型有和更新的设置保存到您的数据存储。