我想知道我可以在sparksql中使用更新查询,就像:
sqlContext.sql("update users set name = '*' where name is null")
Run Code Online (Sandbox Code Playgroud)
我收到了错误:
org.apache.spark.sql.AnalysisException:
Unsupported language features in query:update users set name = '*' where name is null
Run Code Online (Sandbox Code Playgroud)
如果sparksql不支持更新查询或我是否正确编写代码?