Skip to content

Commit 3886a0c

Browse files
committed
fix
1 parent ce63c68 commit 3886a0c

File tree

2 files changed

+3
-23
lines changed

2 files changed

+3
-23
lines changed

crates/iceberg/src/catalog/mod.rs

+1
Original file line numberDiff line numberDiff line change
@@ -678,6 +678,7 @@ pub(super) mod _serde {
678678
sequence_number: i64,
679679
timestamp_ms: i64,
680680
manifest_list: String,
681+
#[serde(default)]
681682
summary: SnapshotSummary,
682683
#[serde(skip_serializing_if = "Option::is_none")]
683684
schema_id: Option<SchemaId>,

crates/iceberg/src/spec/snapshot.rs

+2-23
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ impl Operation {
6666
}
6767
}
6868

69-
/// Summarises the changes in the snapshot.
69+
/// Summarizes the changes in the snapshot.
7070
#[derive(Debug, Serialize, Deserialize, PartialEq, Eq, Clone, Default)]
7171
#[serde(default)]
7272
pub struct SnapshotSummary {
@@ -115,11 +115,6 @@ pub struct SnapshotSummary {
115115
/// Total position delete files
116116
pub total_pos_deletes: u64,
117117

118-
/// Number of added delete vectors
119-
pub added_dvs: u64,
120-
/// Number of removed delete vectors
121-
pub removed_dvs: u64,
122-
123118
/// Number of deleted duplicate files
124119
pub deleted_duplicate_files: u64,
125120

@@ -176,8 +171,6 @@ impl SnapshotSummary {
176171
added_pos_delete_files: 0,
177172
removed_pos_delete_files: 0,
178173
total_pos_deletes: 0,
179-
added_dvs: 0,
180-
removed_dvs: 0,
181174
deleted_duplicate_files: 0,
182175
changed_partition_count: 0,
183176
partitions: HashMap::new(),
@@ -288,21 +281,7 @@ impl SnapshotSummary {
288281
size
289282
);
290283
}
291-
292-
/// Adds a delete vector file.
293-
pub fn add_dv(&mut self, size: u64) {
294-
self.added_dvs = self.added_dvs.saturating_add(1);
295-
self.added_file_size = self.added_file_size.saturating_add(size);
296-
self.total_file_size = self.total_file_size.saturating_add(size);
297-
}
298-
299-
/// Removes a DV (delete vector) file.
300-
pub fn remove_dv(&mut self, size: u64) {
301-
self.removed_dvs = self.removed_dvs.saturating_add(1);
302-
self.removed_file_size = self.removed_file_size.saturating_add(size);
303-
self.total_file_size = self.total_file_size.saturating_sub(size);
304-
}
305-
284+
306285
/// Increments the counter for deleted duplicate files by one.
307286
pub fn increment_deleted_duplicate_files(&mut self) {
308287
self.deleted_duplicate_files = self.deleted_duplicate_files.saturating_add(1);

0 commit comments

Comments
 (0)