Skip to content

Commit 2f5eaa9

Browse files
committed
[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. (cherry picked from commit 847efe1) Signed-off-by: Sean Owen <sowen@cloudera.com>
1 parent 9a4341b commit 2f5eaa9

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ private[sql] object Dataset {
131131
*
132132
* people.filter("age > 30")
133133
* .join(department, people("deptId") === department("id"))
134-
* .groupBy(department("name"), "gender")
134+
* .groupBy(department("name"), people("gender"))
135135
* .agg(avg(people("salary")), max(people("age")))
136136
* }}}
137137
*
@@ -141,9 +141,9 @@ private[sql] object Dataset {
141141
* Dataset<Row> people = spark.read().parquet("...");
142142
* Dataset<Row> department = spark.read().parquet("...");
143143
*
144-
* people.filter("age".gt(30))
145-
* .join(department, people.col("deptId").equalTo(department("id")))
146-
* .groupBy(department.col("name"), "gender")
144+
* people.filter(people.col("age").gt(30))
145+
* .join(department, people.col("deptId").equalTo(department.col("id")))
146+
* .groupBy(department.col("name"), people.col("gender"))
147147
* .agg(avg(people.col("salary")), max(people.col("age")));
148148
* }}}
149149
*

0 commit comments

Comments
 (0)