Skip to content

Commit

Permalink
python style
Browse files Browse the repository at this point in the history
  • Loading branch information
zhichao-li committed Jul 3, 2015
1 parent d85ae0b commit 3e9f5ae
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions python/pyspark/sql/functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -435,6 +435,7 @@ def shiftRight(col, numBits):
jc = sc._jvm.functions.shiftRight(_to_java_column(col), numBits)
return Column(jc)


@since(1.5)
def shiftRightUnsigned(col, numBits):
"""Unsigned shift the the given value numBits right.
Expand All @@ -447,6 +448,7 @@ def shiftRightUnsigned(col, numBits):
jc = sc._jvm.functions.shiftRightUnsigned(_to_java_column(col), numBits)
return Column(jc)


@since(1.4)
def sparkPartitionId():
"""A column for partition ID of the Spark task.
Expand Down

0 comments on commit 3e9f5ae

Please sign in to comment.