Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r187761743
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -775,6 +775,178 @@ object functions {
*/
def
Github user rxin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r187751801
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -775,6 +775,178 @@ object functions {
*/
def var_pop(columnName:
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/21054
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r186616594
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,190 @@
+/*
+ *
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r186020071
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,190 @@
+/*
+ * Licensed
Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185800917
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,190 @@
+/*
+ * Licensed
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185791203
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,190 @@
+/*
+ * Licensed
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185783983
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -36,6 +36,8 @@ case class Fact(date: Int, hour: Int, minute:
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
Github user kiszk commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185564388
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185468199
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -36,6 +36,8 @@ case class Fact(date: Int, hour: Int, minute:
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185461822
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala
---
@@ -85,4 +65,29 @@ case class Average(child:
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185462735
--- Diff:
sql/core/src/test/resources/sql-tests/inputs/udaf-regrfunctions.sql ---
@@ -0,0 +1,61 @@
+--
+-- Licensed to the Apache Software
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185461620
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Corr.scala
---
@@ -22,18 +22,14 @@ import
Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185460008
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala
---
@@ -62,14 +52,6 @@ case class Average(child:
Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185460040
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -686,4 +687,72 @@ class DataFrameAggregateSuite extends
Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185460147
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -686,4 +687,72 @@ class DataFrameAggregateSuite extends
Github user kiszk commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185448281
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,193 @@
+/*
+ * Licensed to
Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185444248
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,193 @@
+/*
+ * Licensed
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185411834
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,193 @@
+/*
+ * Licensed
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185409726
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Corr.scala
---
@@ -51,7 +47,27 @@ case class Corr(x: Expression,
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185409402
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/CentralMomentAgg.scala
---
@@ -128,6 +100,36 @@ abstract class
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185407773
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala
---
@@ -85,4 +67,28 @@ case class Average(child:
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185407606
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala
---
@@ -85,4 +67,28 @@ case class Average(child:
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185403679
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala
---
@@ -23,23 +23,13 @@ import
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185402034
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -686,4 +687,72 @@ class DataFrameAggregateSuite extends
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185401222
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -36,6 +36,8 @@ case class Fact(date: Int, hour: Int, minute:
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185400649
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala ---
@@ -686,4 +687,72 @@ class DataFrameAggregateSuite extends
Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185399774
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Corr.scala
---
@@ -22,18 +22,14 @@ import
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185170928
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala
---
@@ -23,23 +23,13 @@ import
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185170552
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala
---
@@ -62,14 +52,6 @@ case class Average(child:
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185171846
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/regression.scala
---
@@ -0,0 +1,193 @@
+/*
+ * Licensed
GitHub user mgaido91 opened a pull request:
https://github.com/apache/spark/pull/21054
[SPARK-23907][SQL] Add regr_* functions
## What changes were proposed in this pull request?
The PR introduces regr_slope, regr_intercept, regr_r2, regr_sxx, regr_syy,
regr_sxy,
33 matches
Mail list logo