refactor: integrate fuse table block pruning into pipeline

src/query/catalog/src/table.rs

@@ -218,6 +218,17 @@ pub trait Table: Sync + Send {
         )))
     }
 
+    fn build_prune_pipeline(
+        &self,
+        table_ctx: Arc<dyn TableContext>,
+        plan: &DataSourcePlan,
+        source_pipeline: &mut Pipeline,
+    ) -> Result<Option<Pipeline>> {
+        let (_, _, _) = (table_ctx, plan, source_pipeline);
+
+        Ok(None)
+    }
+
     /// Assembly the pipeline of appending data to storage
     fn append_data(&self, ctx: Arc<dyn TableContext>, pipeline: &mut Pipeline) -> Result<()> {
         let (_, _) = (ctx, pipeline);

src/query/service/src/pipelines/builders/builder_scan.rs

@@ -43,6 +43,15 @@ impl PipelineBuilder {
         self.ctx.set_partitions(scan.source.parts.clone())?;
         self.ctx
             .set_wait_runtime_filter(scan.scan_id, self.contain_sink_processor);
+        if self.ctx.get_settings().get_enable_prune_pipeline()? {
+            if let Some(prune_pipeline) = table.build_prune_pipeline(
+                self.ctx.clone(),
+                &scan.source,
+                &mut self.main_pipeline,
+            )? {
+                self.pipelines.push(prune_pipeline);
+            }
+        }
         table.read_data(
             self.ctx.clone(),
             &scan.source,

src/query/service/tests/it/storages/fuse/mod.rs

@@ -19,6 +19,7 @@ mod io;
 mod meta;
 mod operations;
 mod pruning;
+mod pruning_pipeline;
 mod statistics;
 mod table;
 mod table_functions;