aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/sql/group.py
diff options
context:
space:
mode:
authorDavies Liu <davies@databricks.com>2015-05-20 23:05:54 -0700
committerReynold Xin <rxin@databricks.com>2015-05-20 23:05:54 -0700
commit8ddcb25b3990ec691463f87d4071e7425f4909a9 (patch)
tree954ef5cb66813835c5e0ede7de7aa415e96f793b /python/pyspark/sql/group.py
parent04940c49755fd2e7f1ed7b875da287c946bfebeb (diff)
downloadspark-8ddcb25b3990ec691463f87d4071e7425f4909a9.tar.gz
spark-8ddcb25b3990ec691463f87d4071e7425f4909a9.tar.bz2
spark-8ddcb25b3990ec691463f87d4071e7425f4909a9.zip
[SPARK-7606] [SQL] [PySpark] add version to Python SQL API docs
Add version info for public Python SQL API. cc rxin Author: Davies Liu <davies@databricks.com> Closes #6295 from davies/versions and squashes the following commits: cfd91e6 [Davies Liu] add more version for DataFrame API 600834d [Davies Liu] add version to SQL API docs
Diffstat (limited to 'python/pyspark/sql/group.py')
-rw-r--r--python/pyspark/sql/group.py10
1 files changed, 10 insertions, 0 deletions
diff --git a/python/pyspark/sql/group.py b/python/pyspark/sql/group.py
index 9f7c743c05..4da472a577 100644
--- a/python/pyspark/sql/group.py
+++ b/python/pyspark/sql/group.py
@@ -16,6 +16,7 @@
#
from pyspark.rdd import ignore_unicode_prefix
+from pyspark.sql import since
from pyspark.sql.column import Column, _to_seq
from pyspark.sql.dataframe import DataFrame
from pyspark.sql.types import *
@@ -47,6 +48,8 @@ class GroupedData(object):
"""
A set of methods for aggregations on a :class:`DataFrame`,
created by :func:`DataFrame.groupBy`.
+
+ .. versionadded:: 1.3
"""
def __init__(self, jdf, sql_ctx):
@@ -54,6 +57,7 @@ class GroupedData(object):
self.sql_ctx = sql_ctx
@ignore_unicode_prefix
+ @since(1.3)
def agg(self, *exprs):
"""Compute aggregates and returns the result as a :class:`DataFrame`.
@@ -86,6 +90,7 @@ class GroupedData(object):
return DataFrame(jdf, self.sql_ctx)
@dfapi
+ @since(1.3)
def count(self):
"""Counts the number of records for each group.
@@ -94,6 +99,7 @@ class GroupedData(object):
"""
@df_varargs_api
+ @since(1.3)
def mean(self, *cols):
"""Computes average values for each numeric columns for each group.
@@ -108,6 +114,7 @@ class GroupedData(object):
"""
@df_varargs_api
+ @since(1.3)
def avg(self, *cols):
"""Computes average values for each numeric columns for each group.
@@ -122,6 +129,7 @@ class GroupedData(object):
"""
@df_varargs_api
+ @since(1.3)
def max(self, *cols):
"""Computes the max value for each numeric columns for each group.
@@ -132,6 +140,7 @@ class GroupedData(object):
"""
@df_varargs_api
+ @since(1.3)
def min(self, *cols):
"""Computes the min value for each numeric column for each group.
@@ -144,6 +153,7 @@ class GroupedData(object):
"""
@df_varargs_api
+ @since(1.3)
def sum(self, *cols):
"""Compute the sum for each numeric columns for each group.