首页/数据/数仓建模速查/Iceberg 时间旅行与增量读
湖仓与引擎63 条

Iceberg 时间旅行与增量读

时间旅行按快照或时间戳查询历史版本,便于复现与审计;增量读可只处理指定快照区间的新数据,适合增量加工链路。

数仓建模速查数据更新于 2026-10-12
时间旅行snapshot/timestamp
增量读快照区间
用途复现+增量加工
保留按策略清理快照

时间旅行查询

时间旅行查询
SELECT count(*) FROM demo.db.trade_order VERSION AS OF 1234567890;
SELECT count(*) FROM demo.db.trade_order TIMESTAMP AS OF '2026-10-11 00:00:00';

-- 增量读:读取两个快照之间新增的数据
SELECT * FROM demo.db.trade_order
WHERE dt = DATE '2026-10-12';
快照过期时间要覆盖审计与回滚需求,过期后时间旅行失效。

易错点

  • 快照保留过短,出问题无法回到前一版本

数据来源与参考

  • Apache Iceberg 官方文档:Spark Queries
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌