Skip to content

Commit 864a810

Browse files
committed
Fix stats not calculated correctly
Signed-off-by: Xuanwo <[email protected]>
1 parent 02008f5 commit 864a810

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/query/storages/iceberg/src/statistics.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,16 +116,16 @@ impl IcebergStatistics {
116116
statistics.number_of_data_files += 1;
117117

118118
data_file.column_sizes().iter().for_each(|(col_id, size)| {
119-
column_sizes.insert(*col_id, *size);
119+
*column_sizes.entry(*col_id).or_default() += size;
120120
});
121121
data_file.value_counts().iter().for_each(|(col_id, count)| {
122-
value_counts.insert(*col_id, *count);
122+
*value_counts.entry(*col_id).or_default() += count;
123123
});
124124
data_file
125125
.null_value_counts()
126126
.iter()
127127
.for_each(|(col_id, count)| {
128-
null_value_counts.insert(*col_id, *count);
128+
*null_value_counts.entry(*col_id).or_default() += count;
129129
});
130130
data_file
131131
.nan_value_counts()

0 commit comments

Comments
 (0)