Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185783832
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -686,4 +687,72 @@ class DataFrameAggregateSuite extends QueryTest with
SharedSQLContext {
}
}
}
+
+ test("SPARK-23907: regression functions") {
+ val emptyTableData = Seq.empty[(Double, Double)].toDF("a", "b")
+ val correlatedData = Seq[(Double, Double)]((2, 3), (3, 4), (7.5, 8.2),
(10.3, 12))
+ .toDF("a", "b")
+ val correlatedDataWithNull = Seq[(java.lang.Double, java.lang.Double)](
+ (2.0, 3.0), (3.0, null), (7.5, 8.2), (10.3, 12.0)).toDF("a", "b")
--- End diff --
ok, thanks!
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
