|
31 | 31 | import org.elasticsearch.compute.operator.LimitOperator; |
32 | 32 | import org.elasticsearch.compute.operator.LocalSourceOperator; |
33 | 33 | import org.elasticsearch.compute.operator.LocalSourceOperator.LocalSourceFactory; |
34 | | -import org.elasticsearch.compute.operator.MergeOperator; |
35 | 34 | import org.elasticsearch.compute.operator.MvExpandOperator; |
36 | 35 | import org.elasticsearch.compute.operator.Operator; |
37 | 36 | import org.elasticsearch.compute.operator.Operator.OperatorFactory; |
|
103 | 102 | import org.elasticsearch.xpack.esql.plan.physical.LimitExec; |
104 | 103 | import org.elasticsearch.xpack.esql.plan.physical.LocalSourceExec; |
105 | 104 | import org.elasticsearch.xpack.esql.plan.physical.LookupJoinExec; |
106 | | -import org.elasticsearch.xpack.esql.plan.physical.MergeExec; |
107 | 105 | import org.elasticsearch.xpack.esql.plan.physical.MvExpandExec; |
108 | 106 | import org.elasticsearch.xpack.esql.plan.physical.OutputExec; |
109 | 107 | import org.elasticsearch.xpack.esql.plan.physical.PhysicalPlan; |
@@ -281,8 +279,6 @@ else if (node instanceof OutputExec outputExec) { |
281 | 279 | return planOutput(outputExec, context); |
282 | 280 | } else if (node instanceof ExchangeSinkExec exchangeSink) { |
283 | 281 | return planExchangeSink(exchangeSink, context); |
284 | | - } else if (node instanceof MergeExec mergeExec) { |
285 | | - return planMerge(mergeExec, context); |
286 | 282 | } else if (node instanceof RrfScoreEvalExec rrf) { |
287 | 283 | return planRrfScoreEvalExec(rrf, context); |
288 | 284 | } |
@@ -804,13 +800,6 @@ private PhysicalOperation planChangePoint(ChangePointExec changePoint, LocalExec |
804 | 800 | ); |
805 | 801 | } |
806 | 802 |
|
807 | | - private PhysicalOperation planMerge(MergeExec mergeExec, LocalExecutionPlannerContext context) { |
808 | | - Layout.Builder layout = new Layout.Builder(); |
809 | | - layout.append(mergeExec.output()); |
810 | | - MergeOperator.BlockSuppliers suppliers = () -> mergeExec.suppliers().stream().map(s -> s.get()).toList(); |
811 | | - return PhysicalOperation.fromSource(new MergeOperator.MergeOperatorFactory(suppliers), layout.build()); |
812 | | - } |
813 | | - |
814 | 803 | /** |
815 | 804 | * Immutable physical operation. |
816 | 805 | */ |
|
0 commit comments