Delta Lake MERGE INTO 声明答案

【问题标题】：Delta Lake MERGE INTO statementDelta Lake MERGE INTO 声明
【发布时间】：2020-07-14 17:33:59
【问题描述】：

我正在尝试运行 Delta Lake MERGE INTO

MERGE INTO sessions
USING updates
ON sessions.sessionId = updates.sessionId
WHEN MATCHED THEN UPDATE *
WHEN NOT MATCHED THEN INSERT *

我收到一个 SQL 错误

ParseException: mismatched input 'MERGE' expecting {'(', 'SELECT', 'FROM', 'ADD', 'DESC', 'WITH', 'VALUES', 'CREATE', 'TABLE', 'INSERT', 'DELETE', 'DESCRIBE', 'EXPLAIN', 'SHOW', 'USE', 'DROP', 'ALTER', 'MAP', 'SET', 'RESET', 'START', 'COMMIT', 'ROLLBACK', 'REDUCE', 'REFRESH', 'CLEAR', 'CACHE', 'UNCACHE', 'DFS', 'TRUNCATE', 'ANALYZE', 'LIST', 'REVOKE', 'GRANT', 'LOCK', 'UNLOCK', 'MSCK', 'EXPORT', 'IMPORT', 'LOAD'}(line 2, pos 0)
== SQL ==
MERGE INTO sessions
^^^
USING updates
ON sessions.sessionId = updates.sessionId
WHEN MATCHED THEN UPDATE *
WHEN NOT MATCHED THEN INSERT *
"

我正在使用io.delta:delta-core_2.11:0.6.1 我做错了什么？

谢谢

【问题讨论】：

标签： apache-spark delta-lake

【解决方案1】：

Delta Lake 0.7.0 中添加了merge SQL 支持。您还需要将 Apache Spark 升级到 3.0.0 并启用与 Apache Spark DataSourceV2 和目录 API 的集成，以便使用 Delta Lake 0.7.0 中的新 SQL 支持。请查看 Delta Lake 文档中的 instructions。

【讨论】：