Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/22030#discussion_r208468429
--- 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 --
Hm? I think we should allow it and then make this
https://github.com/apache/spark/pull/22030#discussion_r208456164 assumption
stay true.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
