Skip to content

Commit 446a1c9

Browse files
authored
[analytics-engine] Collapse AggregateDecompositionResolver into BackendPlanAdapter's adaptNode chain (opensearch-project#21645)
Signed-off-by: Sandesh Kumar <sandeshkr419@gmail.com>
1 parent c99b12e commit 446a1c9

6 files changed

Lines changed: 266 additions & 865 deletions

File tree

sandbox/plugins/analytics-engine/src/main/java/org/opensearch/analytics/exec/DefaultPlanExecutor.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.opensearch.analytics.planner.CapabilityRegistry;
2525
import org.opensearch.analytics.planner.PlannerContext;
2626
import org.opensearch.analytics.planner.PlannerImpl;
27-
import org.opensearch.analytics.planner.dag.AggregateDecompositionResolver;
2827
import org.opensearch.analytics.planner.dag.BackendPlanAdapter;
2928
import org.opensearch.analytics.planner.dag.DAGBuilder;
3029
import org.opensearch.analytics.planner.dag.FragmentConversionDriver;
@@ -133,7 +132,6 @@ private void executeInternal(RelNode logicalFragment, ActionListener<Iterable<Ob
133132
QueryDAG dag = DAGBuilder.build(plan, capabilityRegistry, clusterService);
134133
PlanForker.forkAll(dag, capabilityRegistry);
135134
BackendPlanAdapter.adaptAll(dag, capabilityRegistry);
136-
AggregateDecompositionResolver.resolveAll(dag, capabilityRegistry);
137135
FragmentConversionDriver.convertAll(dag, capabilityRegistry);
138136
logger.debug("[DefaultPlanExecutor] QueryDAG:\n{}", dag);
139137

0 commit comments

Comments
 (0)