Skip to content

Commit ea3fa45

Browse files
committed
confused
1 parent d5ac764 commit ea3fa45

File tree

2 files changed

+3
-15
lines changed

2 files changed

+3
-15
lines changed

crates/iceberg/src/spec/manifest/entry.rs

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -130,12 +130,6 @@ impl ManifestEntry {
130130
self.snapshot_id
131131
}
132132

133-
/// File sequence number
134-
#[inline]
135-
pub fn file_sequence_number(&self) -> Option<i64> {
136-
self.file_sequence_number
137-
}
138-
139133
/// Data sequence number.
140134
#[inline]
141135
pub fn sequence_number(&self) -> Option<i64> {

crates/iceberg/src/transaction/rewrite_files.rs

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,7 @@ impl TransactionAction for RewriteFilesAction {
143143
}
144144

145145
fn copy_with_deleted_status(entry: &ManifestEntryRef) -> Result<ManifestEntry> {
146+
// todo should we fail on missing properties?
146147
let builder = ManifestEntry::builder()
147148
.status(ManifestStatus::Deleted)
148149
.snapshot_id(entry.snapshot_id().ok_or_else(|| {
@@ -163,15 +164,8 @@ fn copy_with_deleted_status(entry: &ManifestEntryRef) -> Result<ManifestEntry> {
163164
),
164165
)
165166
})?)
166-
.file_sequence_number(entry.file_sequence_number().ok_or_else(|| {
167-
Error::new(
168-
ErrorKind::DataInvalid,
169-
format!(
170-
"Missing file_sequence_number for entry with file path: {}",
171-
entry.file_path()
172-
),
173-
)
174-
})?)
167+
// todo copy file seq no as well
168+
175169
.data_file(entry.data_file().clone());
176170

177171
Ok(builder.build())

0 commit comments

Comments
 (0)