178178import static org .elasticsearch .xpack .esql .expression .predicate .operator .comparison .EsqlBinaryComparison .BinaryComparisonOperation .GTE ;
179179import static org .elasticsearch .xpack .esql .expression .predicate .operator .comparison .EsqlBinaryComparison .BinaryComparisonOperation .LT ;
180180import static org .elasticsearch .xpack .esql .expression .predicate .operator .comparison .EsqlBinaryComparison .BinaryComparisonOperation .LTE ;
181- <<<<<<< HEAD
182- =======
183- import static org .elasticsearch .xpack .esql .optimizer .rules .logical .DeduplicateAggsTests .aggFieldName ;
184- import static org .elasticsearch .xpack .esql .optimizer .rules .logical .DeduplicateAggsTests .aliased ;
185- import static org .elasticsearch .xpack .esql .optimizer .rules .logical .OptimizerRules .TransformDirection .DOWN ;
186- import static org .elasticsearch .xpack .esql .optimizer .rules .logical .OptimizerRules .TransformDirection .UP ;
187- >>>>>>> 0 a81875703ed (Fixes esql class cast bug in STATS at planning level (#137511 ))
188181import static org .hamcrest .Matchers .allOf ;
189182import static org .hamcrest .Matchers .anyOf ;
190183import static org .hamcrest .Matchers .contains ;
@@ -480,7 +473,6 @@ public void testAggsWithOverridingInputAndGrouping() throws Exception {
480473 }
481474
482475 /**
483- <<<<<<< HEAD
484476 * Project[[s{r}#4 AS d, s{r}#4, last_name{f}#21, first_name{f}#18]]
485477 * \_Limit[1000[INTEGER]]
486478 * \_Aggregate[[last_name{f}#21, first_name{f}#18],[SUM(salary{f}#22) AS s, last_name{f}#21, first_name{f}#18]]
@@ -503,9 +495,6 @@ public void testCombineProjectionWithDuplicateAggregation() {
503495 }
504496
505497 /**
506- =======
507- * <pre>{@code
508- >>>>>>> 0a81875703ed (Fixes esql class cast bug in STATS at planning level (#137511))
509498 * Limit[1000[INTEGER]]
510499 * \_Aggregate[STANDARD,[],[SUM(salary{f}#12,true[BOOLEAN]) AS sum(salary), SUM(salary{f}#12,last_name{f}#11 == [44 6f 65][KEYW
511500 * ORD]) AS sum(salary) WheRe last_name == "Doe"]]
@@ -3820,7 +3809,6 @@ public void testPruneRenameOnAggBy() {
38203809 }
38213810
38223811 /**
3823- <<<<<<< HEAD
38243812 * Expects
38253813 * Project[[c1{r}#2, c2{r}#4, cs{r}#6, cm{r}#8, cexp{r}#10]]
38263814 * \_Eval[[c1{r}#2 AS c2, c1{r}#2 AS cs, c1{r}#2 AS cm, c1{r}#2 AS cexp]]
@@ -3983,8 +3971,6 @@ public void testEliminateDuplicateRenamedGroupings() {
39833971 }
39843972
39853973 /**
3986- =======
3987- >>>>>>> 0a81875703ed (Fixes esql class cast bug in STATS at planning level (#137511))
39883974 * Expected
39893975 * Limit[2[INTEGER]]
39903976 * \_Filter[a{r}#6 > 2[INTEGER]]
@@ -4075,6 +4061,19 @@ public void testLimitZeroUsesLocalRelation() {
40754061 assertThat (plan , instanceOf (LocalRelation .class ));
40764062 }
40774063
4064+ private <T > T aliased (Expression exp , Class <T > clazz ) {
4065+ var alias = as (exp , Alias .class );
4066+ return as (alias .child (), clazz );
4067+ }
4068+
4069+ private <T extends AggregateFunction > void aggFieldName (Expression exp , Class <T > aggType , String fieldName ) {
4070+ var alias = as (exp , Alias .class );
4071+ var af = as (alias .child (), aggType );
4072+ var field = af .field ();
4073+ var name = field .foldable () ? BytesRefs .toString (field .fold (FoldContext .small ())) : Expressions .name (field );
4074+ assertThat (name , is (fieldName ));
4075+ }
4076+
40784077 /**
40794078 * Expects
40804079 * Limit[1000[INTEGER]]
@@ -4832,7 +4831,6 @@ public void testStatsExpOverAggsWithScalars() {
48324831
48334832 /**
48344833 * Expects
4835- <<<<<<< HEAD
48364834 * Project[[a{r}#5, b{r}#9, $$max(salary)_+_3>$COUNT$2{r}#46 AS d, $$count(salary)_->$MIN$3{r}#47 AS e, $$avg(salary)_+_m
48374835 * >$MAX$1{r}#45 AS g]]
48384836 * \_Eval[[$$$$avg(salary)_+_m>$AVG$0$SUM$0{r}#48 / $$max(salary)_+_3>$COUNT$2{r}#46 AS $$avg(salary)_+_m>$AVG$0, $$avg(
@@ -4904,9 +4902,6 @@ public void testStatsExpOverAggsWithScalarAndDuplicateAggs() {
49044902
49054903 /**
49064904 * Expects
4907- =======
4908- * <pre>{@code
4909- >>>>>>> 0a81875703ed (Fixes esql class cast bug in STATS at planning level (#137511))
49104905 * Project[[a{r}#5, a{r}#5 AS b, w{r}#12]]
49114906 * \_Limit[1000[INTEGER]]
49124907 * \_Aggregate[[w{r}#12],[SUM($$salary_/_2_+_la>$SUM$0{r}#26) AS a, w{r}#12]]
0 commit comments