Skip to content

Conversation

@geruh
Copy link
Contributor

@geruh geruh commented Jul 29, 2025

Closes #1210

Summary

This work was primarily done by @rutb327 while I provided guidance!

This PR adds equality delete read support to PyIceberg by implementing the delete file indexing system that matches delete files to data files, mimicking the behavior found in Iceberg Core. With this implementation we are able to index files and now read equality deletes during table scans.

Design details

Delete File Index

The new DeleteFileIndex class centralizes handling of all delete file types: positional deletes, equality deletes, and deletion vectors. It organizes deletes by type (equality vs. positional), partition (using PartitionMap for spec-aware grouping), and path (for path-specific positional deletes). This enables efficient lookup during table scans, reducing unnecessary delete file processing.

Equality Delete support

Equality delete files are loaded as PyArrow Tables with their respective equality ids for the schema and for each we are grouping tables with the same set equality id's to reduce anti join operations.

Testing

Added tests from the core iceberg DeleteFileIndex test suite and added some tests with dummy files. As well as some manual testing with a flink setup.

table_eq with only equality deletes on id=2, id=5
+---+-------+
| id|   data|
+---+-------+
|  1|  Alice|
|  3|Charlie|
|  4|  David|
|  6|  Frank|
+---+-------+

table_eq_pos with equality deletes and positional delete at position 3
+---+-----+
| id| data|
+---+-----+
|  1|Alice|
|  4|David|
|  6|Frank|
+---+-----+

Are there any user-facing changes?

Yes can read tables with equality deletes

@gabeiglio
Copy link
Contributor

I noticed that this PR addresses the same issue/feature as the one I was working on in here. However, your implementation is more complete (by supporting reading equality deletes and deletion vectors), so I think it makes sense to move forward with this one instead. (cc: @sungwy, since you reviewed my PR)

@kevinjqliu
Copy link
Contributor

kevinjqliu commented Jul 31, 2025

oops, sorry @gabeiglio, I was searching for positional deletes in github search and i didnt see that you were already working on it in that PR. Looks like there are some parts of the PR that is still super useful to get merged, like the validates.

@gabeiglio
Copy link
Contributor

Yea exactly, should have been more clear on my message, my implementation for DeleteFileIndex was a scope creep to achieve the validation. so now that PR can be only for the validation instead of partition maps, delete file index, etc. :) @kevinjqliu

Copy link
Collaborator

@sungwy sungwy left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hi @geruh - thanks for working on this PR, and sorry for the delayed review.

I've added some review feedback. Let me know your thoughts!

@rutb327
Copy link
Contributor

rutb327 commented Aug 14, 2025

@sungwy Thanks a lot! I have done the suggested changes, could you take another look at it?

Copy link
Collaborator

@sungwy sungwy left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hi @rutb327 thank you for continuing to work on the PR!

I've added a few more suggestions after taking longer time reading your implementation and the test suite. Hope you find this helpful!

@Fokko Fokko self-requested a review August 26, 2025 16:41
if self.dv:
if not self.dv_sorted:
self.dv_values = sorted(self.dv.values(), key=lambda x: x[1])
self.dv_sorted = True
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Instead of needing to track whether we are sorted here is there a better data structure that just is sorted that we could use?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We went with the lazy sort pattern here to follow the Java implementation. This allows us to add each file in O(1), then sort once in n log n. We technically could use sorted containers SortedList for roughly the same performance. WDYT

@jayceslesar
Copy link
Contributor

Also I will test, but will this DeleteFileIndex class properly map deletes to data files? In the current implementation pyiceberg maps dangling delete files

@KazuhitoT
Copy link

Hi, I hope this PR can be included in 0.11.0.

In the current implementation pyiceberg maps dangling delete files

It seems that position delete files with referenced_data_file set (and no bounds) might not be covered by this logic.
I tried a small change in my fork here:
KazuhitoT@b0965d0

If this approach makes sense, would you consider adding a similar change to this PR?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[feature request] Support reading equality delete files

8 participants