rf targets to cte

englefly · Sep 13, 2024 · 5dfa890 · 5dfa890
1 parent 258ec3d
commit 5dfa890
Show file tree

Hide file tree

Showing 4 changed files with 112 additions and 183 deletions.
diff --git a/...e-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java b/...e-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
@@ -1238,9 +1238,6 @@ public PlanFragment visitPhysicalCTEProducer(PhysicalCTEProducer<? extends Plan>
         multiCastPlanFragment.setOutputExprs(outputs);
         context.getCteProduceFragments().put(cteId, multiCastPlanFragment);
         context.getCteProduceMap().put(cteId, cteProducer);
-        if (context.getRuntimeTranslator().isPresent()) {
-            context.getRuntimeTranslator().get().getContext().getCteProduceMap().put(cteId, cteProducer);
-        }
         context.getPlanFragments().add(multiCastPlanFragment);
         return child;
     }

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java
@@ -27,7 +27,6 @@
 import org.apache.doris.nereids.trees.expressions.Slot;
 import org.apache.doris.nereids.trees.plans.Plan;
 import org.apache.doris.nereids.trees.plans.physical.AbstractPhysicalJoin;
-import org.apache.doris.nereids.trees.plans.physical.PhysicalCTEProducer;
 import org.apache.doris.nereids.trees.plans.physical.PhysicalHashJoin;
 import org.apache.doris.nereids.trees.plans.physical.PhysicalRelation;
 import org.apache.doris.nereids.trees.plans.physical.RuntimeFilter;
@@ -118,11 +117,6 @@ public boolean equals(Object other) {
 
     private final Map<Plan, EffectiveSrcType> effectiveSrcNodes = Maps.newHashMap();
 
-    private final Map<CTEId, PhysicalCTEProducer> cteProducerMap = Maps.newLinkedHashMap();
-
-    // cte whose runtime filter has been extracted
-    private final Set<CTEId> processedCTE = Sets.newHashSet();
-
     private final SessionVariable sessionVariable;
 
     private final FilterSizeLimits limits;
@@ -160,10 +154,6 @@ public RuntimeFilterContext(SessionVariable sessionVariable) {
         this.limits = new FilterSizeLimits(sessionVariable);
     }
 
-    public void setRelationsUsedByPlan(Plan plan, Set<PhysicalRelation> relations) {
-        relationsUsedByPlan.put(plan, relations);
-    }
-
     /**
      * return true, if the relation is in the subtree
      */
@@ -185,14 +175,6 @@ public FilterSizeLimits getLimits() {
         return limits;
     }
 
-    public Map<CTEId, PhysicalCTEProducer> getCteProduceMap() {
-        return cteProducerMap;
-    }
-
-    public Set<CTEId> getProcessedCTE() {
-        return processedCTE;
-    }
-
     public void setTargetExprIdToFilter(ExprId id, RuntimeFilter filter) {
         Preconditions.checkArgument(filter.getTargetSlots().stream().anyMatch(expr -> expr.getExprId() == id));
         this.targetExprIdToFilter.computeIfAbsent(id, k -> Lists.newArrayList()).add(filter);