| 核心 | JSON 事务日志 + 数据文件,按版本提交 |
|---|---|
| 能力 | MERGE upsert、时间旅行、schema 约束 |
| 维护 | 小文件合并、历史清理(VACUUM) |
MERGE 与时间旅行(Spark SQL)
MERGE 与时间旅行(Spark SQL)
MERGE INTO delta.`/data/orders` AS t
USING updates AS s ON t.order_id = s.order_id
WHEN MATCHED THEN UPDATE SET *
WHEN NOT MATCHED THEN INSERT *;
SELECT * FROM delta.`/data/orders` VERSION AS OF 12;
VACUUM delta.`/data/orders` RETAIN 168 HOURS;VACUUM 会物理删除保留期外文件,正在读取的旧版本会失败;保留期要覆盖最长查询与回滚窗口。