Skip to content

Commit 057381a

Browse files
committed
fail hard if not LocalSourceExec
1 parent 0e0ef78 commit 057381a

File tree

1 file changed

+3
-2
lines changed
  • x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/physical

1 file changed

+3
-2
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/physical/MergeExec.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,13 +23,14 @@ public class MergeExec extends PhysicalPlan {
2323

2424
public MergeExec(Source source, List<PhysicalPlan> children, List<Attribute> output) {
2525
super(source, children);
26-
// this.physSubPlans = physSubPlans;
2726
this.output = output;
2827
}
2928

29+
/**
30+
* Extracts the children as a list of suppliers. All children must be LocalSourceExec.
31+
*/
3032
public List<LocalSupplier> suppliers() {
3133
return children().stream()
32-
.filter(p -> LocalSourceExec.class.isAssignableFrom(p.getClass()))
3334
.map(LocalSourceExec.class::cast)
3435
.map(LocalSourceExec::supplier)
3536
.toList();

0 commit comments

Comments
 (0)