aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala
diff options
context:
space:
mode:
Diffstat (limited to 'sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala5
1 files changed, 1 insertions, 4 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala b/sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala
index 45a63ae26e..a5e6b638d2 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala
@@ -127,10 +127,7 @@ class GroupedData protected[sql](df: DataFrame, groupingExprs: Seq[Expression])
* {{{
* // Selects the age of the oldest employee and the aggregate expense for each department
* import com.google.common.collect.ImmutableMap;
- * df.groupBy("department").agg(ImmutableMap.<String, String>builder()
- * .put("age", "max")
- * .put("expense", "sum")
- * .build());
+ * df.groupBy("department").agg(ImmutableMap.of("age", "max", "expense", "sum"));
* }}}
*/
def agg(exprs: java.util.Map[String, String]): DataFrame = {