Skip to content

Commit

Permalink
break doctest line
Browse files Browse the repository at this point in the history
  • Loading branch information
Hanan Shteingart committed Jan 1, 2019
1 parent e54d2f7 commit 3d9a751
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions python/pyspark/sql/dataframe.py
Expand Up @@ -2060,14 +2060,16 @@ def transform(self, func):
... return df.withColumn("something", lit(something))
>>> data = [("jose", 1), ("li", 2), ("liz", 3)]
>>> source_df = spark.createDataFrame(data, ["name", "age"])
>>> actual_df = source_df.transform(with_greeting).transform(lambda x: with_something(x, "crazy"))
>>> actual_df = (source_df
... .transform(with_greeting)
... .transform(lambda x: with_something(x, "nice")))
>>> actual_df.show()
+----+---+--------+---------+
|name|age|greeting|something|
+----+---+--------+---------+
|jose| 1| hi| crazy|
| li| 2| hi| crazy|
| liz| 3| hi| crazy|
|jose| 1| hi| nice|
| li| 2| hi| nice|
| liz| 3| hi| nice|
+----+---+--------+---------+
"""
res = func(self)
Expand Down

0 comments on commit 3d9a751

Please sign in to comment.