|
17 | 17 | import static org.opensearch.sql.planner.physical.PhysicalPlanDSL.dedupe;
|
18 | 18 | import static org.opensearch.sql.planner.physical.PhysicalPlanDSL.eval;
|
19 | 19 | import static org.opensearch.sql.planner.physical.PhysicalPlanDSL.filter;
|
| 20 | +import static org.opensearch.sql.planner.physical.PhysicalPlanDSL.flatten; |
20 | 21 | import static org.opensearch.sql.planner.physical.PhysicalPlanDSL.limit;
|
21 | 22 | import static org.opensearch.sql.planner.physical.PhysicalPlanDSL.project;
|
22 | 23 | import static org.opensearch.sql.planner.physical.PhysicalPlanDSL.rareTopN;
|
@@ -129,6 +130,8 @@ public static Stream<Arguments> getPhysicalPlanForTest() {
|
129 | 130 |
|
130 | 131 | PhysicalPlan eval = eval(plan, Pair.of(ref, ref));
|
131 | 132 |
|
| 133 | + PhysicalPlan flatten = flatten(plan, ref); |
| 134 | + |
132 | 135 | PhysicalPlan sort = sort(plan, Pair.of(SortOption.DEFAULT_ASC, ref));
|
133 | 136 |
|
134 | 137 | PhysicalPlan takeOrdered = takeOrdered(plan, 1, 1, Pair.of(SortOption.DEFAULT_ASC, ref));
|
@@ -161,6 +164,7 @@ public static Stream<Arguments> getPhysicalPlanForTest() {
|
161 | 164 | Arguments.of(window, "window"),
|
162 | 165 | Arguments.of(remove, "remove"),
|
163 | 166 | Arguments.of(eval, "eval"),
|
| 167 | + Arguments.of(flatten, "flatten"), |
164 | 168 | Arguments.of(sort, "sort"),
|
165 | 169 | Arguments.of(takeOrdered, "takeOrdered"),
|
166 | 170 | Arguments.of(dedupe, "dedupe"),
|
|
0 commit comments