Delta Lake中使用Replace Where SQL子句报错求助

问题根源 #

你的SQL语法使用错误：INSERT INTO是追加数据的操作，而REPLACE WHERE属于选择性覆盖逻辑，必须搭配INSERT OVERWRITE使用，而非INSERT INTO，这才触发了语法解析异常。

修正后的SQL语句 #

将insert into替换为insert overwrite，正确语句如下：

insert overwrite table delta.`/path-to-table/` replace where replace_key in ('a', 'b') select * from vwt_df

补充说明 #

选择性覆盖的核心是用新数据替换REPLACE WHERE条件匹配到的旧数据，该逻辑仅支持基于INSERT OVERWRITE语法触发，INSERT INTO不兼容REPLACE WHERE子句。

内容的提问来源于stack exchange，提问作者bda