Skip to content

Commit 336c974

Browse files
committed
rebase and ignore optional fields when copying deleted status
1 parent 02ca330 commit 336c974

File tree

2 files changed

+9
-16
lines changed

2 files changed

+9
-16
lines changed

crates/iceberg/src/transaction/rewrite_files.rs

Lines changed: 5 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@ use super::snapshot::{DefaultManifestProcess, SnapshotProduceOperation, Snapshot
2525
use super::{ActionCommit, TransactionAction};
2626
use crate::error::{Error, ErrorKind, Result};
2727
use crate::spec::{
28-
DataContentType, DataFile, ManifestContentType, ManifestEntry, ManifestEntryRef, ManifestFile,
29-
ManifestStatus, Operation,
28+
DataContentType, DataFile, ManifestContentType, ManifestEntry, ManifestFile, ManifestStatus,
29+
Operation,
3030
};
3131
use crate::table::Table;
3232
use crate::transaction::validate::SnapshotValidator;
@@ -170,18 +170,12 @@ impl TransactionAction for RewriteFilesAction {
170170
}
171171

172172
fn copy_with_deleted_status(entry: &ManifestEntry) -> Result<ManifestEntry> {
173-
let mut builder = ManifestEntry::builder()
173+
let builder = ManifestEntry::builder()
174174
.status(ManifestStatus::Deleted)
175+
.snapshot_id_opt(entry.snapshot_id())
176+
.sequence_number_opt(entry.sequence_number())
175177
.data_file(entry.data_file().clone());
176178

177-
if let Some(snapshot_id) = entry.snapshot_id() {
178-
builder = builder.snapshot_id(snapshot_id);
179-
}
180-
181-
if let Some(sequence_number) = entry.sequence_number() {
182-
builder = builder.sequence_number(sequence_number);
183-
}
184-
185179
// todo copy file seq no as well
186180

187181
Ok(builder.build())

crates/iceberg/src/transaction/snapshot.rs

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -23,11 +23,10 @@ use uuid::Uuid;
2323

2424
use crate::error::Result;
2525
use crate::spec::{
26-
DataContentType, DataFile, DataFileFormat, FormatVersion, MAIN_BRANCH, ManifestContentType, ManifestEntry,
27-
ManifestFile, ManifestListWriter, ManifestWriter, ManifestWriterBuilder, Operation,
28-
PROPERTY_WRITE_PARTITION_SUMMARY_LIMIT, PROPERTY_WRITE_PARTITION_SUMMARY_LIMIT_DEFAULTSnapshot,
29-
SnapshotReference, SnapshotRetention, SnapshotSummaryCollector, Struct, StructType, Summary,
30-
TableProperties, update_snapshot_summaries,
26+
DataContentType, DataFile, DataFileFormat, FormatVersion, MAIN_BRANCH, ManifestContentType,
27+
ManifestEntry, ManifestFile, ManifestListWriter, ManifestWriter, ManifestWriterBuilder,
28+
Operation, Snapshot, SnapshotReference, SnapshotRetention, SnapshotSummaryCollector, Struct,
29+
StructType, Summary, TableProperties, update_snapshot_summaries,
3130
};
3231
use crate::table::Table;
3332
use crate::transaction::ActionCommit;

0 commit comments

Comments
 (0)