Skip to content

Commit 5517625

Browse files
committed
updated merged tests
1 parent 3d811bd commit 5517625

File tree

2 files changed

+7
-9
lines changed

2 files changed

+7
-9
lines changed

x-pack/plugin/esql/qa/testFixtures/src/main/resources/inlinestats.csv-spec

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1407,7 +1407,7 @@ total_duration:long | day:date | days:date
14071407
;
14081408

14091409
evalBeforeDoubleInlinestats1
1410-
required_capability: inlinestats_v10
1410+
required_capability: inlinestats_v11
14111411

14121412
FROM employees
14131413
| EVAL salaryK = salary/1000
@@ -1427,7 +1427,7 @@ emp_no:integer |still_hired:boolean|count:long
14271427
;
14281428

14291429
evalBeforeDoubleInlinestats2
1430-
required_capability: inlinestats_v10
1430+
required_capability: inlinestats_v11
14311431

14321432
FROM employees
14331433
| EVAL jobs = MV_COUNT(job_positions)

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/optimizer/LogicalPlanOptimizerTests.java

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6127,12 +6127,11 @@ public void testInlineStatsWithAggGetsPrunedEntirely() {
61276127
* \_InlineJoin[LEFT,[],[],[]]
61286128
* |_Project[[avg{r}#1053, decades{r}#1049, idecades{r}#1056]]
61296129
* | \_Eval[[$$SUM$avg$0{r$}#1073 / $$COUNT$avg$1{r$}#1074 AS avg#1053, decades{r}#1049 / 2[INTEGER] AS idecades#1056]]
6130-
* | \_Limit[1000[INTEGER],false]
6131-
* | \_Aggregate[[decades{r}#1049],[SUM(salary{f}#1072,true[BOOLEAN],compensated[KEYWORD]) AS $$SUM$avg$0#1073,
6130+
* | \_Aggregate[[decades{r}#1049],[SUM(salary{f}#1072,true[BOOLEAN],compensated[KEYWORD]) AS $$SUM$avg$0#1073,
61326131
* COUNT(salary{f}#1072,true[BOOLEAN]) AS $$COUNT$avg$1#1074, decades{r}#1049]]
6133-
* | \_Eval[[DATEDIFF(years[KEYWORD],birth_date{f}#1071,1755626308505[DATETIME]) AS age#1043, age{r}#1043 / 10[INTEGER] AS
6132+
* | \_Eval[[DATEDIFF(years[KEYWORD],birth_date{f}#1071,1755626308505[DATETIME]) AS age#1043, age{r}#1043 / 10[INTEGER] AS
61346133
* decades#1046, decades{r}#1046 * 10[INTEGER] AS decades#1049]]
6135-
* | \_EsRelation[employees][birth_date{f}#1071, salary{f}#1072]
6134+
* | \_EsRelation[employees][birth_date{f}#1071, salary{f}#1072]
61366135
* \_Project[[avgavg{r}#1063]]
61376136
* \_Eval[[$$SUM$avgavg$0{r$}#1077 / $$COUNT$avgavg$1{r$}#1078 AS avgavg#1063]]
61386137
* \_Aggregate[[],[SUM(avg{r}#1053,true[BOOLEAN],compensated[KEYWORD]) AS $$SUM$avgavg$0#1077,
@@ -6158,15 +6157,14 @@ public void testInlineStatsWithAggAndInlineStatsGetsPruned() {
61586157

61596158
var project = as(plan, EsqlProject.class);
61606159
assertThat(Expressions.names(project.projections()), is(List.of("avg", "decades", "avgavg")));
6161-
var limit = asLimit(project.child(), 1000, true);
6160+
var limit = asLimit(project.child(), 1000, false);
61626161
var inlineJoin = as(limit.child(), InlineJoin.class);
61636162

61646163
// Left branch: Project with avg, decades, idecades
61656164
var leftProject = as(inlineJoin.left(), Project.class);
61666165
assertThat(Expressions.names(leftProject.projections()), is(List.of("avg", "decades", "idecades")));
61676166
var leftEval = as(leftProject.child(), Eval.class);
6168-
var leftLimit = asLimit(leftEval.child(), 1000, false);
6169-
var leftAggregate = as(leftLimit.child(), Aggregate.class);
6167+
var leftAggregate = as(leftEval.child(), Aggregate.class);
61706168
assertThat(Expressions.names(leftAggregate.output()), is(List.of("$$SUM$avg$0", "$$COUNT$avg$1", "decades")));
61716169
var leftEval2 = as(leftAggregate.child(), Eval.class);
61726170
var leftRelation = as(leftEval2.child(), EsRelation.class);

0 commit comments

Comments
 (0)