Skip to content

Commit 29c4696

Browse files
committed
Unit test should have similar styles.
1 parent 23743e1 commit 29c4696

File tree

1 file changed

+28
-23
lines changed

1 file changed

+28
-23
lines changed

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/RemoveRedundantAliasAndProjectSuite.scala

Lines changed: 28 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -45,9 +45,10 @@ class RemoveRedundantAliasAndProjectSuite extends PlanTest with PredicateHelper
4545

4646
test("all expressions in project list are aliased child output but with different order") {
4747
val relation = LocalRelation('a.int, 'b.int)
48-
val query = relation.select('b, 'a).analyze
49-
val optimized = Optimize.execute(relation.select('b as 'b, 'a as 'a).analyze)
50-
comparePlans(optimized, query)
48+
val query = relation.select('b as 'b, 'a as 'a).analyze
49+
val optimized = Optimize.execute(query)
50+
val expected = relation.select('b, 'a).analyze
51+
comparePlans(optimized, expected)
5152
}
5253

5354
test("some expressions in project list are aliased child output") {
@@ -59,16 +60,18 @@ class RemoveRedundantAliasAndProjectSuite extends PlanTest with PredicateHelper
5960

6061
test("some expressions in project list are aliased child output but with different order") {
6162
val relation = LocalRelation('a.int, 'b.int)
62-
val query = relation.select('b, 'a).analyze
63-
val optimized = Optimize.execute(relation.select('b as 'b, 'a).analyze)
64-
comparePlans(optimized, query)
63+
val query = relation.select('b as 'b, 'a).analyze
64+
val optimized = Optimize.execute(query)
65+
val expected = relation.select('b, 'a).analyze
66+
comparePlans(optimized, expected)
6567
}
6668

6769
test("some expressions in project list are not Alias or Attribute") {
6870
val relation = LocalRelation('a.int, 'b.int)
69-
val query = relation.select('a, 'b + 1).analyze
70-
val optimized = Optimize.execute(relation.select('a as 'a, 'b + 1).analyze)
71-
comparePlans(optimized, query)
71+
val query = relation.select('a as 'a, 'b + 1).analyze
72+
val optimized = Optimize.execute(query)
73+
val expected = relation.select('a, 'b + 1).analyze
74+
comparePlans(optimized, expected)
7275
}
7376

7477
test("some expressions in project list are aliased child output but with metadata") {
@@ -83,32 +86,34 @@ class RemoveRedundantAliasAndProjectSuite extends PlanTest with PredicateHelper
8386
test("retain deduplicating alias in self-join") {
8487
val relation = LocalRelation('a.int)
8588
val fragment = relation.select('a as 'a)
86-
val query = relation.join(relation.select('a as 'a)).analyze
87-
val optimized = Optimize.execute(
88-
fragment.select('a as 'a).join(fragment.select('a as 'a)).analyze)
89-
comparePlans(optimized, query)
89+
val query = fragment.select('a as 'a).join(fragment.select('a as 'a)).analyze
90+
val optimized = Optimize.execute(query)
91+
val expected = relation.join(relation.select('a as 'a)).analyze
92+
comparePlans(optimized, expected)
9093
}
9194

9295
test("alias removal should not break after push project through union") {
9396
val r1 = LocalRelation('a.int)
9497
val r2 = LocalRelation('b.int)
95-
val optimized = Optimize.execute(
96-
r1.select('a as 'a).union(r2.select('b as 'b)).select('a).analyze)
97-
val query = r1.union(r2)
98-
comparePlans(optimized, query)
98+
val query = r1.select('a as 'a).union(r2.select('b as 'b)).select('a).analyze
99+
val optimized = Optimize.execute(query)
100+
val expected = r1.union(r2)
101+
comparePlans(optimized, expected)
99102
}
100103

101104
test("remove redundant alias from aggregate") {
102105
val relation = LocalRelation('a.int, 'b.int)
103-
val optimized = Optimize.execute(relation.groupBy('a as 'a)('a as 'a, sum('b)).analyze)
104-
val query = relation.groupBy('a)('a, sum('b)).analyze
105-
comparePlans(optimized, query)
106+
val query = relation.groupBy('a as 'a)('a as 'a, sum('b)).analyze
107+
val optimized = Optimize.execute(query)
108+
val expected = relation.groupBy('a)('a, sum('b)).analyze
109+
comparePlans(optimized, expected)
106110
}
107111

108112
test("remove redundant alias from window") {
109113
val relation = LocalRelation('a.int, 'b.int)
110-
val optimized = Optimize.execute(relation.window(Seq('b as 'b), Seq('a as 'a), Seq()).analyze)
111-
val query = relation.window(Seq('b), Seq('a), Seq()).analyze
112-
comparePlans(optimized, query)
114+
val query = relation.window(Seq('b as 'b), Seq('a as 'a), Seq()).analyze
115+
val optimized = Optimize.execute(query)
116+
val expected = relation.window(Seq('b), Seq('a), Seq()).analyze
117+
comparePlans(optimized, expected)
113118
}
114119
}

0 commit comments

Comments
 (0)