Github user maryannxue commented on a diff in the pull request:
https://github.com/apache/spark/pull/22030#discussion_r208451663
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/RelationalGroupedDataset.scala ---
@@ -335,7 +337,7 @@ class RelationalGroupedDataset protected[sql](
* @since 1.6.0
*/
def pivot(pivotColumn: String, values: Seq[Any]):
RelationalGroupedDataset = {
- pivot(Column(pivotColumn), values)
+ pivot(Column(pivotColumn), values.map(lit))
--- End diff --
Yes, you did. This "old" interface only takes in a single named column
(say, "a", but not "a+1") by its name, but we turn it into a `Column` just to
reuse the same implementation.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
