Skip to content

Commit a631195

Browse files
committed
1 parent 8b41dd0 commit a631195

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

sql/core/src/test/scala/org/apache/spark/sql/RewritePredicateSubqueryEndToEndSuite.scala

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -30,13 +30,16 @@ class RewritePredicateSubqueryEndToEndSuite extends QueryTest with SharedSparkSe
3030
val df = sql(
3131
"""
3232
|SELECT *
33-
|FROM t1
33+
|FROM t1
3434
|WHERE a IN (SELECT x
35-
| FROM (SELECT x AS x,
36-
| Rank() OVER (partition BY x ORDER BY Sum(y) DESC) AS ranking
37-
| FROM t2
38-
| GROUP BY x) tmp1
39-
| WHERE ranking <= 5)
35+
| FROM (SELECT x AS x,
36+
| Rank()
37+
| OVER (
38+
| PARTITION BY x
39+
| ORDER BY Sum(y) DESC) AS ranking
40+
| FROM t2
41+
| GROUP BY x) tmp1
42+
| WHERE ranking <= 5)
4043
|""".stripMargin)
4144

4245
df.collect()

0 commit comments

Comments
 (0)