File tree Expand file tree Collapse file tree 1 file changed +10
-10
lines changed
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -78,10 +78,10 @@ class RewriteDistinctAggregatesSuite extends PlanTest {
7878
7979 test(" eliminate multiple distinct groups due to superficial differences" ) {
8080 val input = testRelation
81- .groupBy(' a )(
82- countDistinct(' b + ' c ).as(' agg1 ),
83- countDistinct(' c + ' b ).as(' agg2 ),
84- max(' c ).as(' agg3 ))
81+ .groupBy($ " a " )(
82+ countDistinct($ " b " + $ " c " ).as(" agg1" ),
83+ countDistinct($ " c " + $ " b " ).as(" agg2" ),
84+ max($ " c " ).as(" agg3" ))
8585 .analyze
8686
8787 val rewrite = RewriteDistinctAggregates (input)
@@ -93,12 +93,12 @@ class RewriteDistinctAggregatesSuite extends PlanTest {
9393
9494 test(" reduce multiple distinct groups due to superficial differences" ) {
9595 val input = testRelation
96- .groupBy(' a )(
97- countDistinct(' b + ' c + ' d ).as(' agg1 ),
98- countDistinct(' d + ' c + ' b ).as(' agg2 ),
99- countDistinct(' b + ' c ).as(' agg4 ),
100- countDistinct(' c + ' b ).as(' agg4 ),
101- max(' c ).as(' agg5 ))
96+ .groupBy($ " a " )(
97+ countDistinct($ " b " + $ " c " + $ " d " ).as(" agg1" ),
98+ countDistinct($ " d " + $ " c " + $ " b " ).as(" agg2" ),
99+ countDistinct($ " b " + $ " c " ).as(" agg3 " ),
100+ countDistinct($ " c " + $ " b " ).as(" agg4" ),
101+ max($ " c " ).as(" agg5" ))
102102 .analyze
103103
104104 val rewrite = RewriteDistinctAggregates (input)
You can’t perform that action at this time.
0 commit comments