| 时间线 | 提交历史 |
|---|---|
| 增量查询 | 按时间点拉取 |
| 归档 | 定期归档旧提交 |
| 清理 | 保留策略 |
增量查询
增量查询
SET hoodie.<table>.consume.mode=INCREMENTAL;
SET hoodie.<table>.consume.start.timestamp=20261012080000;
SELECT * FROM hudi_trade_order WHERE dt = '2026-10-12';增量查询要配合归档与清理策略:归档过早会丢失增量起点。
时间线记录每次提交(commit、deltacommit、compaction),增量查询可按时间点拉取变更;需要关注归档配置,避免时间线过长影响性能。
| 时间线 | 提交历史 |
|---|---|
| 增量查询 | 按时间点拉取 |
| 归档 | 定期归档旧提交 |
| 清理 | 保留策略 |
SET hoodie.<table>.consume.mode=INCREMENTAL;
SET hoodie.<table>.consume.start.timestamp=20261012080000;
SELECT * FROM hudi_trade_order WHERE dt = '2026-10-12';