From 847efe12656756f9ad6a4dc14bd183ac1a0760a6 Mon Sep 17 00:00:00 2001
From: Sean Owen <sowen@cloudera.com>
Date: Thu, 8 Jun 2017 10:56:23 +0100
Subject: [PATCH] [SPARK-20914][DOCS] Javadoc contains code that is invalid
## What changes were proposed in this pull request?
Fix Java, Scala Dataset examples in scaladoc, which didn't compile.
## How was this patch tested?
Existing compilation/test
Author: Sean Owen <sowen@cloudera.com>
Closes #18215 from srowen/SPARK-20914.
---
.../src/main/scala/org/apache/spark/sql/Dataset.scala | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
index 8abec85ee1..f7637e005f 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
@@ -131,7 +131,7 @@ private[sql] object Dataset {
*
* people.filter("age > 30")
* .join(department, people("deptId") === department("id"))
- * .groupBy(department("name"), "gender")
+ * .groupBy(department("name"), people("gender"))
* .agg(avg(people("salary")), max(people("age")))
* }}}
*
@@ -141,9 +141,9 @@ private[sql] object Dataset {
* Dataset<Row> people = spark.read().parquet("...");
* Dataset<Row> department = spark.read().parquet("...");
*
- * people.filter("age".gt(30))
- * .join(department, people.col("deptId").equalTo(department("id")))
- * .groupBy(department.col("name"), "gender")
+ * people.filter(people.col("age").gt(30))
+ * .join(department, people.col("deptId").equalTo(department.col("id")))
+ * .groupBy(department.col("name"), people.col("gender"))
* .agg(avg(people.col("salary")), max(people.col("age")));
* }}}
*
--
GitLab