Skip to content

Commit f0b0d93

Browse files
committed
add column min max state
1 parent 0eb6279 commit f0b0d93

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>,
@@ -420,7 +420,7 @@ impl StreamBlockProperties {
420420
let data_type = DataType::from(field.data_type());
421421
if RangeIndex::supported_type(&data_type) && column_id != ORIGIN_BLOCK_ROW_NUM_COLUMN_ID
422422
{
423-
stats_columns.push(column_id);
423+
stats_columns.push((column_id, data_type.clone()));
424424
if !bloom_column_ids.contains(&column_id) {
425425
distinct_columns.push((column_id, data_type));
426426
}

0 commit comments

Comments
 (0)