File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
src/query/storages/iceberg/src Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -166,17 +166,15 @@ impl IcebergStatistics {
166166
167167 let mut computed_statistics = HashMap :: new ( ) ;
168168 for field in IcebergTable :: get_schema ( table) ?. fields ( ) {
169- // The column id in iceberg is 1-based while the column id in Databend is 0-based.
170- let iceberg_col_id = field. column_id as i32 + 1 ;
171- let column_stats = get_column_stats (
169+ let column_stats: Option < BasicColumnStatistics > = get_column_stats (
172170 field,
173171 & column_sizes,
174172 & lower_bounds,
175173 & upper_bounds,
176174 & null_value_counts,
177175 ) ;
178176 if let Some ( stats) = column_stats {
179- computed_statistics. insert ( iceberg_col_id as ColumnId , stats) ;
177+ computed_statistics. insert ( field . column_id , stats) ;
180178 }
181179 }
182180
You can’t perform that action at this time.
0 commit comments