Skip to content

Commit 35c3c31

Browse files
committed
ready to start testing
1 parent 98b1c27 commit 35c3c31

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

crates/iceberg/src/transaction/rewrite_files.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@ pub struct RewriteFilesAction {
3333
key_metadata: Option<Vec<u8>>,
3434
snapshot_properties: HashMap<String, String>,
3535
data_files_to_add: Vec<DataFile>,
36-
// Data files and delete files to delete
3736
data_files_to_delete: Vec<DataFile>,
3837
}
3938

@@ -106,7 +105,7 @@ impl TransactionAction for RewriteFilesAction {
106105
}
107106
}
108107

109-
fn set_deleted_status(entry: &ManifestEntryRef) -> Result<ManifestEntry> {
108+
fn copy_with_deleted_status(entry: &ManifestEntryRef) -> Result<ManifestEntry> {
110109
let builder = ManifestEntry::builder()
111110
.status(ManifestStatus::Deleted)
112111
.snapshot_id(entry.snapshot_id().ok_or_else(|| {
@@ -165,7 +164,7 @@ impl SnapshotProduceOperation for RewriteFilesOperation {
165164
.iter()
166165
.any(|f| f.file_path == entry.data_file().file_path)
167166
{
168-
deleted_entries.push(set_deleted_status(entry)?);
167+
deleted_entries.push(copy_with_deleted_status(entry)?);
169168
}
170169
}
171170
}

0 commit comments

Comments
 (0)