Simplify test sql statements.

dongjoon-hyun · dongjoon-hyun · commit b2ac335fedac · 2016-04-27T10:54:51.000-07:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala
@@ -433,10 +433,10 @@ class DataFrameAggregateSuite extends QueryTest with SharedSQLContext {
 
   test("SPARK-14664: Decimal sum/avg over window should work.") {
     checkAnswer(
-      sqlContext.sql("select sum(a) over () from (select explode(array(1.0,2.0,3.0)) a) t"),
+      sqlContext.sql("select sum(a) over () from values 1.0, 2.0, 3.0 T(a)"),
       Row(6.0) :: Row(6.0) :: Row(6.0) :: Nil)
     checkAnswer(
-      sqlContext.sql("select avg(a) over () from (select explode(array(1.0,2.0,3.0)) a) t"),
+      sqlContext.sql("select avg(a) over () from values 1.0, 2.0, 3.0 T(a)"),
       Row(2.0) :: Row(2.0) :: Row(2.0) :: Nil)
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -433,10 +433,10 @@ class DataFrameAggregateSuite extends QueryTest with SharedSQLContext {`
`433`	`433`
`434`	`434`	`test("SPARK-14664: Decimal sum/avg over window should work.") {`
`435`	`435`	`checkAnswer(`
`436`		`- sqlContext.sql("select sum(a) over () from (select explode(array(1.0,2.0,3.0)) a) t"),`
	`436`	`+ sqlContext.sql("select sum(a) over () from values 1.0, 2.0, 3.0 T(a)"),`
`437`	`437`	`Row(6.0) :: Row(6.0) :: Row(6.0) :: Nil)`
`438`	`438`	`checkAnswer(`
`439`		`- sqlContext.sql("select avg(a) over () from (select explode(array(1.0,2.0,3.0)) a) t"),`
	`439`	`+ sqlContext.sql("select avg(a) over () from values 1.0, 2.0, 3.0 T(a)"),`
`440`	`440`	`Row(2.0) :: Row(2.0) :: Row(2.0) :: Nil)`
`441`	`441`	`}`
`442`	`442`	`}`