delta lake合并到语句中

uelo1irk  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(516)

我在试着管理三角洲湖 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` 我做错什么了?
谢谢
0x6upsns

0x6upsns1#

这个 merge delta lake 0.7.0中添加了sql支持。您还需要将apachespark升级到3.0.0,并启用与apachespark datasourcev2和catalogapi的集成,以便在delta lake 0.7.0中使用新的sql支持。请查看delta lake文档中的说明。

相关问题