apache-spark-sql - Databricks 增量更新

Question

我们如何使用 databricks delta 从其他表中更新表中的多个记录。

我想实现类似：

update ExistingTable set
IsQualified = updates.IsQualified From updates  where ExistingTable.key= updates.key

它失败并出现错误：不匹配的输入'来自'期待

Answer 1

现在您可以使用5.0 Beta或Official使用MERGE INTO4.0 之后固定的 10K 限制来执行相同的操作。UPSERTs如果需要，我也会提供帮助。

Answer 2

1. 可以将 Merge 用于小型数据集，因为它的当前限制为 10k

此外，更新语句不支持子查询，但它在数据砖团队的积压中。