@@ -567,50 +567,4 @@ public void testDuplicatedAggWithFoldableIdenticalExpressions() {
567567 var countDistinct = as (as (aggregates .get (0 ), Alias .class ).child (), CountDistinct .class );
568568 assertEquals ("scalerank" , as (countDistinct .field (), FieldAttribute .class ).name ());
569569 }
570-
571- /**
572- * Limit[1000[INTEGER],false,false]
573- * \_InlineJoin[LEFT,[],[]]
574- * |_EsRelation[airports][abbrev{f}#12, city{f}#18, city_location{f}#19, coun..]
575- * \_Project[[a{r}#5, b{r}#8, c{r}#11]]
576- * \_Eval[[$$COUNTDISTINCT$2*COUNT_DISTINC>$0{r$}#20 * 2[INTEGER] AS a#5, $$COUNTDISTINCT$2*COUNT_DISTINC>$0{r$}#20 * 2[
577- * INTEGER] AS b#8, $$COUNTDISTINCT$2*COUNT_DISTINC>$0{r$}#20 * 2[INTEGER] AS c#11]]
578- * \_Aggregate[[],[COUNTDISTINCT(scalerank{f}#14,true[BOOLEAN],PT0S[TIME_DURATION],100[INTEGER]) AS $$COUNTDISTINCT$2*COUNT_DI
579- * STINC>$0#20]]
580- * \_StubRelation[[abbrev{f}#12, city{f}#18, city_location{f}#19, country{f}#17, location{f}#16, name{f}#13, scalerank{f}#14, ty
581- * pe{f}#15]]
582- */
583- public void testDuplicatedInlineAggWithFoldableIdenticalExpressions () {
584- String query = """
585- FROM airports
586- | INLINE STATS a = 2*COUNT_DISTINCT(scalerank, 100),
587- b = 2*COUNT_DISTINCT(scalerank, 220 - 150 + 30),
588- c = 2*COUNT_DISTINCT(scalerank, 1 + 200 - 80 - 20 - 1)
589- """ ;
590-
591- LogicalPlan plan = planAirports (query );
592- var limit = as (plan , Limit .class );
593- var inlineJoin = as (limit .child (), InlineJoin .class );
594-
595- var project = as (inlineJoin .right (), Project .class );
596- var projections = project .projections ();
597- assertThat (projections , hasSize (3 ));
598-
599- assertEquals ("a" , as (projections .get (0 ), ReferenceAttribute .class ).name ());
600- assertEquals ("b" , as (projections .get (1 ), ReferenceAttribute .class ).name ());
601- assertEquals ("c" , as (projections .get (2 ), ReferenceAttribute .class ).name ());
602-
603- var eval = as (project .child (), Eval .class );
604- var aggregates = as (eval .child (), Aggregate .class ).aggregates ();
605- assertThat (eval .fields (), hasSize (3 ));
606- var firstEvalField = as (as (eval .fields ().get (0 ), Alias .class ).child (), Mul .class );
607- var secondEvalField = as (as (eval .fields ().get (1 ), Alias .class ).child (), Mul .class );
608- var thirdEvalField = as (as (eval .fields ().get (2 ), Alias .class ).child (), Mul .class );
609- assertEquals (firstEvalField , secondEvalField );
610- assertEquals (secondEvalField , thirdEvalField );
611-
612- assertThat (aggregates , hasSize (1 ));
613- var countDistinct = as (as (aggregates .get (0 ), Alias .class ).child (), CountDistinct .class );
614- assertEquals ("scalerank" , as (countDistinct .field (), FieldAttribute .class ).name ());
615- }
616570}
0 commit comments