Skip to content

Commit

Permalink
Style.
Browse files Browse the repository at this point in the history
  • Loading branch information
hvanhovell committed Jan 31, 2016
1 parent b002d60 commit 6e4da4f
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions python/pyspark/sql/functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -275,6 +275,7 @@ def countDistinct(col, *cols):
jc = sc._jvm.functions.countDistinct(_to_java_column(col), _to_seq(sc, cols, _to_java_column))
return Column(jc)


@since(1.3)
def first(col, ignorenulls=False):
"""Aggregate function: returns the first value in a group.
Expand All @@ -283,6 +284,7 @@ def first(col, ignorenulls=False):
jc = sc._jvm.functions.first(_to_java_column(col), ignorenulls)
return Column(jc)


@since(1.6)
def input_file_name():
"""Creates a string column for the file name of the current Spark task.
Expand Down Expand Up @@ -314,6 +316,7 @@ def isnull(col):
sc = SparkContext._active_spark_context
return Column(sc._jvm.functions.isnull(_to_java_column(col)))


@since(1.3)
def last(col, ignorenulls=False):
"""Aggregate function: returns the last value in a group.
Expand All @@ -322,6 +325,7 @@ def last(col, ignorenulls=False):
jc = sc._jvm.functions.last(_to_java_column(col), ignorenulls)
return Column(jc)


@since(1.6)
def monotonically_increasing_id():
"""A column that generates monotonically increasing 64-bit integers.
Expand Down

0 comments on commit 6e4da4f

Please sign in to comment.