This is an automated email from the ASF dual-hosted git repository.
liurenjie1024 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg-rust.git
The following commit(s) were added to refs/heads/main by this push:
new bc86d10c8 refactor(arrow): Rename parameter in delete_filter for
clarity (#1955)
bc86d10c8 is described below
commit bc86d10c8ed85865cef0effae8f6ebca0ff3e358
Author: Robert Mu <[email protected]>
AuthorDate: Wed Dec 24 09:25:51 2025 +0800
refactor(arrow): Rename parameter in delete_filter for clarity (#1955)
The parameter `delete_file_path` in `get_delete_vector_for_path` was
misleading because the function expects a data file path, not a delete
file path. Renaming it to `data_file_path` accurately reflects its
usage.
---
crates/iceberg/src/arrow/delete_filter.rs | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/crates/iceberg/src/arrow/delete_filter.rs
b/crates/iceberg/src/arrow/delete_filter.rs
index e6434e72e..4af9f6b6f 100644
--- a/crates/iceberg/src/arrow/delete_filter.rs
+++ b/crates/iceberg/src/arrow/delete_filter.rs
@@ -82,12 +82,12 @@ impl DeleteFilter {
/// Retrieve a delete vector for a data file
pub(crate) fn get_delete_vector_for_path(
&self,
- delete_file_path: &str,
+ data_file_path: &str,
) -> Option<Arc<Mutex<DeleteVector>>> {
self.state
.read()
.ok()
- .and_then(|st| st.delete_vectors.get(delete_file_path).cloned())
+ .and_then(|st| st.delete_vectors.get(data_file_path).cloned())
}
pub(crate) fn try_start_eq_del_load(&self, file_path: &str) ->
Option<Arc<Notify>> {
