rm unused modify

Author: SkyFan2002

src/query/service/src/pipelines/builders/builder_runtime_filter.rs renamed to src/query/service/src/pipelines/builders/builder_broadcast.rs

@@ -40,7 +40,7 @@ mod builder_recluster;
 mod builder_recursive_cte;
 mod builder_replace_into;
 mod builder_row_fetch;
-mod builder_runtime_filter;
+mod builder_broadcast;
 mod builder_scalar;
 mod builder_scan;
 mod builder_sort;

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

@@ -117,7 +117,7 @@ impl HashJoinDesc {
             from_correlated_subquery: join.from_correlated_subquery,
             broadcast: join.broadcast,
             single_to_inner: join.single_to_inner.clone(),
-            runtime_filter: (&join.runtime_filter_plan).into(),
+            runtime_filter: (&join.runtime_filter).into(),
         })
     }
 

src/query/service/src/pipelines/processors/transforms/hash_join/desc.rs

@@ -246,7 +246,7 @@ impl PhysicalPlanReplacer for Fragmenter {
             broadcast: plan.broadcast,
             single_to_inner: plan.single_to_inner.clone(),
             build_side_cache_info: plan.build_side_cache_info.clone(),
-            runtime_filter_plan: plan.runtime_filter_plan.clone(),
+            runtime_filter: plan.runtime_filter.clone(),
         }))
     }
 

src/query/service/src/schedulers/fragments/fragmenter.rs

@@ -31,8 +31,8 @@ use databend_common_catalog::plan::DataSourcePlan;
 use databend_common_catalog::plan::PartInfoPtr;
 use databend_common_catalog::plan::Partitions;
 use databend_common_catalog::query_kind::QueryKind;
+use databend_common_catalog::runtime_filter_info::RuntimeFilterInfo;
 use databend_common_catalog::runtime_filter_info::RuntimeFilterReady;
-use databend_common_catalog::runtime_filter_info::RuntimeFiltersForScan;
 use databend_common_catalog::statistics::data_cache_statistics::DataCacheMetrics;
 use databend_common_catalog::table::Table;
 use databend_common_catalog::table_context::ContextError;
@@ -924,7 +924,7 @@ impl TableContext for CtxDelegation {
         todo!()
     }
 
-    fn set_runtime_filter(&self, _filters: (IndexType, RuntimeFiltersForScan)) {
+    fn set_runtime_filter(&self, _filters: (IndexType, RuntimeFilterInfo)) {
         todo!()
     }
 

src/query/service/tests/it/sql/exec/get_table_bind_test.rs

@@ -30,8 +30,8 @@ use databend_common_catalog::plan::DataSourcePlan;
 use databend_common_catalog::plan::PartInfoPtr;
 use databend_common_catalog::plan::Partitions;
 use databend_common_catalog::query_kind::QueryKind;
+use databend_common_catalog::runtime_filter_info::RuntimeFilterInfo;
 use databend_common_catalog::runtime_filter_info::RuntimeFilterReady;
-use databend_common_catalog::runtime_filter_info::RuntimeFiltersForScan;
 use databend_common_catalog::statistics::data_cache_statistics::DataCacheMetrics;
 use databend_common_catalog::table::Table;
 use databend_common_catalog::table_context::ContextError;
@@ -789,7 +789,7 @@ impl TableContext for CtxDelegation {
         todo!()
     }
 
-    fn set_runtime_filter(&self, _filters: (IndexType, RuntimeFiltersForScan)) {
+    fn set_runtime_filter(&self, _filters: (IndexType, RuntimeFilterInfo)) {
         todo!()
     }
 

src/query/service/tests/it/storages/fuse/operations/commit.rs

@@ -1523,7 +1523,7 @@ fn hash_join_to_format_tree(
     profs: &HashMap<u32, PlanProfile>,
     context: &mut FormatContext,
 ) -> Result<FormatTreeNode<String>> {
-    for rf in plan.runtime_filter_plan.filters.iter() {
+    for rf in plan.runtime_filter.filters.iter() {
         context
             .scan_id_to_runtime_filters
             .entry(rf.scan_id)
@@ -1557,7 +1557,7 @@ fn hash_join_to_format_tree(
     probe_child.payload = format!("{}(Probe)", probe_child.payload);
 
     let mut build_runtime_filters = vec![];
-    for rf in plan.runtime_filter_plan.filters.iter() {
+    for rf in plan.runtime_filter.filters.iter() {
         let mut s = format!(
             "filter id:{}, build key:{}, probe key:{}, filter type:",
             rf.id,

src/query/sql/src/executor/format.rs

@@ -288,7 +288,7 @@ pub trait PhysicalPlanReplacer {
             output_schema: plan.output_schema.clone(),
             need_hold_hash_table: plan.need_hold_hash_table,
             stat_info: plan.stat_info.clone(),
-            runtime_filter_plan: plan.runtime_filter_plan.clone(),
+            runtime_filter: plan.runtime_filter.clone(),
             broadcast: plan.broadcast,
             single_to_inner: plan.single_to_inner.clone(),
             build_side_cache_info: plan.build_side_cache_info.clone(),

src/query/sql/src/executor/physical_plan_visitor.rs

@@ -107,7 +107,7 @@ pub struct HashJoin {
     // a HashMap for mapping the column indexes to the BlockEntry indexes in DataBlock.
     pub build_side_cache_info: Option<(usize, HashMap<IndexType, usize>)>,
 
-    pub runtime_filter_plan: PhysicalRuntimeFilters,
+    pub runtime_filter: PhysicalRuntimeFilters,
 }
 
 impl HashJoin {
@@ -815,7 +815,7 @@ impl PhysicalPlanBuilder {
         probe_to_build: Vec<(usize, (bool, bool))>,
         output_schema: DataSchemaRef,
         build_side_cache_info: Option<(usize, HashMap<IndexType, usize>)>,
-        runtime_filter_plan: PhysicalRuntimeFilters,
+        runtime_filter: PhysicalRuntimeFilters,
         stat_info: PlanStatsInfo,
     ) -> Result<PhysicalPlan> {
         Ok(PhysicalPlan::HashJoin(HashJoin {
@@ -839,7 +839,7 @@ impl PhysicalPlanBuilder {
             broadcast: is_broadcast,
             single_to_inner: join.single_to_inner.clone(),
             build_side_cache_info,
-            runtime_filter_plan,
+            runtime_filter,
         }))
     }
 
@@ -915,7 +915,7 @@ impl PhysicalPlanBuilder {
         let non_equi_conditions = self.process_non_equi_conditions(join, &merged_schema)?;
 
         // Step 11: Build runtime filter
-        let runtime_filter_desc = self
+        let runtime_filter = self
             .build_runtime_filter(
                 join,
                 s_expr,
@@ -941,7 +941,7 @@ impl PhysicalPlanBuilder {
             probe_to_build,
             output_schema,
             build_side_cache_info,
-            runtime_filter_desc,
+            runtime_filter,
             stat_info,
         )
     }