| 核心 | 快照 + 清单文件描述表状态，写入先提交新快照 |
|---|---|
| 能力 | 隐藏分区、时间旅行、schema 演进、增量读 |
| 维护 | 快照过期、清单合并、小文件 rewrite |
Spark SQL 使用 Iceberg
Spark SQL 使用 Iceberg
CREATE TABLE local.db.orders (
order_id STRING, amount DOUBLE, ts TIMESTAMP
) USING iceberg PARTITIONED BY (days(ts));
INSERT INTO local.db.orders VALUES ('o1', 9.9, TIMESTAMP '2026-10-11 10:00:00');
SELECT * FROM local.db.orders.snapshots; -- 查看快照
SELECT * FROM local.db.orders.history; -- 查看提交历史快照回滚（Spark 过程调用）
快照回滚（Spark 过程调用）
CALL local.system.rollback_to_snapshot('db.orders', 1234567890);隐藏分区让查询可以直接按 ts 过滤而无需感知分区函数，避免“分区列裸用”的维护负担。