Skip to content

Commit c6120e5

Browse files
committed
add column min max state
1 parent 7590fd9 commit c6120e5

File tree

2 files changed

+289
-77
lines changed

2 files changed

+289
-77
lines changed

src/query/storages/fuse/src/io/write/stream/block_builder.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -358,7 +358,7 @@ pub struct StreamBlockProperties {
358358
source_schema: TableSchemaRef,
359359

360360
cluster_stats_builder: Arc<ClusterStatisticsBuilder>,
361-
stats_columns: Vec<ColumnId>,
361+
stats_columns: Vec<(ColumnId, DataType)>,
362362
distinct_columns: Vec<(ColumnId, DataType)>,
363363
bloom_columns_map: BTreeMap<FieldIndex, TableField>,
364364
ngram_args: Vec<NgramArgs>,
@@ -417,7 +417,7 @@ impl StreamBlockProperties {
417417
let data_type = DataType::from(field.data_type());
418418
if RangeIndex::supported_type(&data_type) && column_id != ORIGIN_BLOCK_ROW_NUM_COLUMN_ID
419419
{
420-
stats_columns.push(column_id);
420+
stats_columns.push((column_id, data_type.clone()));
421421
if !bloom_column_ids.contains(&column_id) {
422422
distinct_columns.push((column_id, data_type));
423423
}

0 commit comments

Comments
 (0)