Uh oh!
There was an error while loading. Please reload this page.
feat: support existing changelog incremental reads - #509
Conversation
JingsongLi
commented
Jul 14, 2026
Please resolve conflicts. |
58fe7cf to
65c2480CompareJingsongLi
commented
Jul 15, 2026
The Delta audit at |
Pandas886
commented
Jul 16, 2026
Fixed in 2f72b51 — PK Delta audit now preserves _VALUE_KIND, and rowkind matches Java’s field ID and varchar length. Added regression coverage too. Thanks for catching this. |
Uh oh!
There was an error while loading. Please reload this page.
Purpose
Linked issue: close#504
Depends on:#508 (Delta/Auto). Please review that one first — this branch is stacked on top of it, so the diff against
maincurrently includes both commits.This adds reading of already-written changelog files (
changelog_manifest_list) plus anAuditLogTableview that exposesrowkindas the first column.Important: this does not generate lookup/compact changelogs. If a snapshot has no changelog list, we just skip it / return empty for that snapshot rather than inventing files.
Brief change log
(start, end]TableScan::plan_snapshot_changelogreusing the existing split pipelineAuditLogTablewrapper:rowkindfirst, optional_SEQUENCE_NUMBERTableRead::to_audit_log_arrowfor Delta (all+I) and Changelog (from_VALUE_KIND)nonechangelog-producer=inputfixtures and multi-snapshot rangesDiff mode is still unsupported here on purpose.
Tests
API and Format
AuditLogTable+ Changelog path on the incremental APIDocumentation
No standalone docs in this PR (SQL docs come with the DataFusion follow-up).
Review tip
If you're looking at the full branch vs
main, the interesting commit for this PR is the top one (feat: support existing changelog incremental reads). The parent is #508.