Skip to content

Commit d06f282

Browse files
author
aokolnychyi
committed
Inline some calls
1 parent 185aba1 commit d06f282

File tree

1 file changed

+4
-8
lines changed

1 file changed

+4
-8
lines changed

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

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -706,14 +706,10 @@ class DataFrameAggregateSuite extends QueryTest with SharedSQLContext {
706706
testData2.groupBy('a).agg(max('b), sum('b).as("s"), count("*").over()).where('s === 3),
707707
Row(1, 2, 3, 3) :: Row(2, 2, 3, 3) :: Row(3, 2, 3, 3) :: Nil)
708708

709-
checkWindowError(
710-
sql("SELECT MIN(AVG(b) OVER(PARTITION BY a)) FROM testData2"))
711-
checkWindowError(
712-
sql("SELECT SUM(b), MAX(RANK() OVER(ORDER BY a)) FROM testData2"))
713-
checkWindowError(
714-
sql("SELECT SUM(b), MAX(RANK() OVER(ORDER BY b)) FROM testData2 GROUP BY a"))
715-
checkWindowError(
716-
sql("SELECT MAX(SUM(SUM(b)) OVER(ORDER BY a)) FROM testData2 GROUP BY a"))
709+
checkWindowError(sql("SELECT MIN(AVG(b) OVER(PARTITION BY a)) FROM testData2"))
710+
checkWindowError(sql("SELECT SUM(b), MAX(RANK() OVER(ORDER BY a)) FROM testData2"))
711+
checkWindowError(sql("SELECT SUM(b), MAX(RANK() OVER(ORDER BY b)) FROM testData2 GROUP BY a"))
712+
checkWindowError(sql("SELECT MAX(SUM(SUM(b)) OVER(ORDER BY a)) FROM testData2 GROUP BY a"))
717713
checkWindowError(
718714
sql("SELECT MAX(RANK() OVER(ORDER BY b)) FROM testData2 GROUP BY a HAVING SUM(b) = 3"))
719715
checkAnswer(

0 commit comments

Comments
 (0)