Move topn pruner back to fuse.

Author: RinChanNOWWW

src/query/storages/fuse/fuse/src/pruning/mod.rs

@@ -14,6 +14,7 @@
 
 mod pruner;
 mod pruning_executor;
+mod topn_pruner;
 
 pub use pruning_executor::BlockIndex;
 pub use pruning_executor::BlockPruner;

src/query/storages/fuse/fuse/src/pruning/pruning_executor.rs

@@ -29,7 +29,6 @@ use common_storages_pruner::limiter_pruner;
 use common_storages_pruner::limiter_pruner::LimiterPruner;
 use common_storages_pruner::range_pruner;
 use common_storages_pruner::range_pruner::RangePruner;
-use common_storages_pruner::topn_pruner;
 use common_storages_table_meta::meta::BlockMeta;
 use common_storages_table_meta::meta::Location;
 use common_storages_table_meta::meta::SegmentInfo;
@@ -41,6 +40,7 @@ use tracing::Instrument;
 use super::pruner;
 use crate::io::MetaReaders;
 use crate::pruning::pruner::Pruner;
+use crate::pruning::topn_pruner;
 
 pub type BlockIndex = (usize, usize);
 type SegmentPruningJoinHandles = Vec<JoinHandle<Result<Vec<(BlockIndex, Arc<BlockMeta>)>>>>;

src/query/storages/pruner/src/topn_pruner.rs renamed to src/query/storages/fuse/fuse/src/pruning/topn_pruner.rs

@@ -24,7 +24,7 @@ use common_storages_table_meta::meta::ColumnStatistics;
 
 use crate::pruning::BlockIndex;
 
-pub(crate) struct TopNPrunner {
+pub struct TopNPrunner {
     schema: DataSchemaRef,
     sort: Vec<(Expression, bool, bool)>,
     limit: usize,

src/query/storages/parquet/src/table_function/read.rs

@@ -144,7 +144,6 @@ impl ParquetTable {
             let mut partitions = Vec::with_capacity(locations.len());
 
             // build row group pruner.
-
             let filter_expr = push_downs.as_ref().map(|extra| extra.filters.as_slice());
             let row_group_pruner = range_pruner::new_range_pruner(&ctx_ref, filter_expr, &schema)?;
 

src/query/storages/pruner/src/lib.rs

@@ -16,4 +16,3 @@
 
 pub mod limiter_pruner;
 pub mod range_pruner;
-pub mod topn_pruner;