Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/22030#discussion_r208420580
--- Diff:
sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java ---
@@ -306,6 +306,22 @@ public void pivot() {
Assert.assertEquals(30000.0, actual.get(1).getDouble(2), 0.01);
}
+ @Test
+ public void pivotColumnValues() {
+ Dataset<Row> df = spark.table("courseSales");
+ List<Row> actual = df.groupBy("year")
+ .pivot(col("course"), Arrays.asList(lit("dotNET"),
lit("Java")))
+ .agg(sum("earnings")).orderBy("year").collectAsList();
--- End diff --
nit: 2 space indentation
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
