File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
sql/core/src/main/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff 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 *
You can’t perform that action at this time.
0 commit comments