sql - 更新查询架构RDD

Question

我在 scala 中使用 schemaRDD 进行一些数据转换。当像这个例子一样使用更新查询时，UPDATE users SET email = 'abc@example.com' WHERE ID = 1我收到以下错误：

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

Answer 1

由于 SchemaRDD 的底层实现（数据结构）是不可变的 RDD，我认为它不支持 UPDATE。如果您想更新某些内容，一种方法是创建一个副本并在那里进行转换并将更新的集合保存到您的数据存储中。