fix

Author: zhyass

src/query/service/src/pipelines/processors/transforms/recluster/range_bound_sampler.rs

@@ -56,7 +56,7 @@ where
     pub fn add_block(&mut self, data: &DataBlock) {
         let rows = data.num_rows();
         assert!(rows > 0);
-        let column = data.get_by_offset(self.offset).to_column(rows);
+        let column = data.get_by_offset(self.offset).to_column();
 
         let sample_size = std::cmp::min(self.sample_size, rows);
         let mut indices = (0..rows).collect::<Vec<_>>();

src/query/service/src/pipelines/processors/transforms/recluster/transform_add_order_column.rs

@@ -16,11 +16,9 @@ use std::marker::PhantomData;
 use std::sync::Arc;
 
 use databend_common_exception::Result;
-use databend_common_expression::BlockEntry;
 use databend_common_expression::DataBlock;
 use databend_common_expression::DataSchemaRef;
 use databend_common_expression::SortColumnDescription;
-use databend_common_expression::Value;
 use databend_common_pipeline_transforms::sort::RowConverter;
 use databend_common_pipeline_transforms::sort::Rows;
 use databend_common_pipeline_transforms::Transform;
@@ -63,10 +61,7 @@ where
             .row_converter
             .convert(&order_by_cols, data.num_rows())?;
         let order_col = rows.to_column();
-        data.add_column(BlockEntry {
-            data_type: order_col.data_type(),
-            value: Value::Column(order_col),
-        });
+        data.add_column(order_col);
         Ok(data)
     }
 }

src/query/service/src/pipelines/processors/transforms/recluster/transform_range_partition_indexer.rs

@@ -19,14 +19,10 @@ use std::time::Instant;
 
 use databend_common_exception::Result;
 use databend_common_expression::types::ArgType;
-use databend_common_expression::types::DataType;
-use databend_common_expression::types::NumberDataType;
 use databend_common_expression::types::UInt64Type;
-use databend_common_expression::BlockEntry;
 use databend_common_expression::BlockMetaInfoDowncast;
 use databend_common_expression::DataBlock;
 use databend_common_expression::FromData;
-use databend_common_expression::Value;
 use databend_common_pipeline_core::processors::Event;
 use databend_common_pipeline_core::processors::InputPort;
 use databend_common_pipeline_core::processors::OutputPort;
@@ -164,10 +160,7 @@ where
             builder.push(low as u64);
         }
 
-        block.add_column(BlockEntry::new(
-            DataType::Number(NumberDataType::UInt64),
-            Value::Column(UInt64Type::from_data(builder)),
-        ));
+        block.add_column(UInt64Type::from_data(builder));
         self.output_data.push_back(block);
         log::info!("Recluster range output: {:?}", start.elapsed());
         Ok(())