aboutsummaryrefslogtreecommitdiff
path: root/sql/catalyst
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2015-11-24 12:54:37 -0800
committerReynold Xin <rxin@databricks.com>2015-11-24 12:54:37 -0800
commitf3152722791b163fa66597b3684009058195ba33 (patch)
treec3b23ead8eaea14229f5b21642d2a4e8c5c191b2 /sql/catalyst
parent81012546ee5a80d2576740af0dad067b0f5962c5 (diff)
downloadspark-f3152722791b163fa66597b3684009058195ba33.tar.gz
spark-f3152722791b163fa66597b3684009058195ba33.tar.bz2
spark-f3152722791b163fa66597b3684009058195ba33.zip
[SPARK-11946][SQL] Audit pivot API for 1.6.
Currently pivot's signature looks like ```scala scala.annotation.varargs def pivot(pivotColumn: Column, values: Column*): GroupedData scala.annotation.varargs def pivot(pivotColumn: String, values: Any*): GroupedData ``` I think we can remove the one that takes "Column" types, since callers should always be passing in literals. It'd also be more clear if the values are not varargs, but rather Seq or java.util.List. I also made similar changes for Python. Author: Reynold Xin <rxin@databricks.com> Closes #9929 from rxin/SPARK-11946.
Diffstat (limited to 'sql/catalyst')
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala1
1 files changed, 1 insertions, 0 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala
index e34fd49be8..68ec688c99 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala
@@ -44,6 +44,7 @@ object Literal {
case a: Array[Byte] => Literal(a, BinaryType)
case i: CalendarInterval => Literal(i, CalendarIntervalType)
case null => Literal(null, NullType)
+ case v: Literal => v
case _ =>
throw new RuntimeException("Unsupported literal type " + v.getClass + " " + v)
}