You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/04/29 18:49:28 UTC
spark git commit: [SQL][Minor] fix java doc for DataFrame.agg
Repository: spark
Updated Branches:
refs/heads/master 3df9c5dd0 -> 81ea42bf3
[SQL][Minor] fix java doc for DataFrame.agg
Author: Wenchen Fan <cl...@outlook.com>
Closes #5712 from cloud-fan/minor and squashes the following commits:
be23064 [Wenchen Fan] fix java doc for DataFrame.agg
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/81ea42bf
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/81ea42bf
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/81ea42bf
Branch: refs/heads/master
Commit: 81ea42bf39db7366e266bc1e5ce7e459fa2ef409
Parents: 3df9c5d
Author: Wenchen Fan <cl...@outlook.com>
Authored: Wed Apr 29 09:49:24 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Wed Apr 29 09:49:24 2015 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/sql/DataFrame.scala | 17 ++++++-----------
1 file changed, 6 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/81ea42bf/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
index 2affba7..0e896e5 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
@@ -623,17 +623,12 @@ class DataFrame private[sql](
}
/**
- * (Scala-specific) Compute aggregates by specifying a map from column name to
- * aggregate methods. The resulting [[DataFrame]] will also contain the grouping columns.
- *
- * The available aggregate methods are `avg`, `max`, `min`, `sum`, `count`.
- * {{{
- * // Selects the age of the oldest employee and the aggregate expense for each department
- * df.groupBy("department").agg(
- * "age" -> "max",
- * "expense" -> "sum"
- * )
- * }}}
+ * (Scala-specific) Aggregates on the entire [[DataFrame]] without groups.
+ * {{
+ * // df.agg(...) is a shorthand for df.groupBy().agg(...)
+ * df.agg("age" -> "max", "salary" -> "avg")
+ * df.groupBy().agg("age" -> "max", "salary" -> "avg")
+ * }}
* @group dfops
*/
def agg(aggExpr: (String, String), aggExprs: (String, String)*): DataFrame = {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org