aboutsummaryrefslogtreecommitdiff
path: root/sql/core
diff options
context:
space:
mode:
authorWenchen Fan <wenchen@databricks.com>2016-01-05 10:23:36 -0800
committerReynold Xin <rxin@databricks.com>2016-01-05 10:23:36 -0800
commit76768337beec6842660db7522ad15c25ee66d346 (patch)
treed58976552a906917b9126712e75a7a2136fbd01c /sql/core
parent9a6ba7e2c538124f539b50512a7f95059f81cc16 (diff)
downloadspark-76768337beec6842660db7522ad15c25ee66d346.tar.gz
spark-76768337beec6842660db7522ad15c25ee66d346.tar.bz2
spark-76768337beec6842660db7522ad15c25ee66d346.zip
[SPARK-12480][FOLLOW-UP] use a single column vararg for hash
address comments in #10435 This makes the API easier to use if user programmatically generate the call to hash, and they will get analysis exception if the arguments of hash is empty. Author: Wenchen Fan <wenchen@databricks.com> Closes #10588 from cloud-fan/hash.
Diffstat (limited to 'sql/core')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/functions.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/functions.scala b/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
index e223e32fd7..1c96f647b6 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
@@ -1820,8 +1820,8 @@ object functions extends LegacyFunctions {
* @since 2.0
*/
@scala.annotation.varargs
- def hash(col: Column, cols: Column*): Column = withExpr {
- new Murmur3Hash((col +: cols).map(_.expr))
+ def hash(cols: Column*): Column = withExpr {
+ new Murmur3Hash(cols.map(_.expr))
}
//////////////////////////////////////////////////////////////////////////////////////////////