Skip to content

Commit

Permalink
Update
Browse files Browse the repository at this point in the history
  • Loading branch information
kaka1992 committed May 12, 2015
1 parent 8218d0a commit 95724c6
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 2 deletions.
2 changes: 2 additions & 0 deletions python/pyspark/sql/dataframe.py
Original file line number Diff line number Diff line change
Expand Up @@ -1416,6 +1416,8 @@ def between(self, lowerBound, upperBound):
def when(self, whenExpr, thenExpr):
if isinstance(whenExpr, Column):
jc = self._jc.when(whenExpr._jc, thenExpr)
else:
raise TypeError("whenExpr should be Column")
return Column(jc)

@ignore_unicode_prefix
Expand Down
9 changes: 7 additions & 2 deletions python/pyspark/sql/functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
from pyspark.rdd import _prepare_for_python_RDD, ignore_unicode_prefix
from pyspark.serializers import PickleSerializer, AutoBatchedSerializer
from pyspark.sql.types import StringType
from pyspark.sql.dataframe import Column, _to_java_column, _to_seq, _create_column_from_literal
from pyspark.sql.dataframe import Column, _to_java_column, _to_seq


__all__ = [
Expand Down Expand Up @@ -152,9 +152,14 @@ def when(whenExpr, thenExpr):
[Row(age=3), Row(age=4)]
>>> df.select(when(df.age == 2, 3).alias("age")).collect()
[Row(age=3), Row(age=None)]
>>> df.select(when(df.age == 2, 3==3).alias("age")).collect()
[Row(age=True), Row(age=None)]
"""
sc = SparkContext._active_spark_context
jc = sc._jvm.functions.when(whenExpr._jc, thenExpr)
if isinstance(whenExpr, Column):
jc = sc._jvm.functions.when(whenExpr._jc, thenExpr)
else:
raise TypeError("whenExpr should be Column")
return Column(jc)

def rand(seed=None):
Expand Down

0 comments on commit 95724c6

Please sign in to comment.