Skip to content

Commit

Permalink
Revert accidental removal
Browse files Browse the repository at this point in the history
  • Loading branch information
icexelloss committed Jan 18, 2018
1 parent 6d505d3 commit 8d2d943
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions python/pyspark/sql/tests.py
Original file line number Diff line number Diff line change
Expand Up @@ -577,6 +577,7 @@ def test_udf_with_order_by_and_limit(self):
my_copy = udf(lambda x: x, IntegerType())
df = self.spark.range(10).orderBy("id")
res = df.select(df.id, my_copy(df.id).alias("copy")).limit(1)
res.explain(True)
self.assertEqual(res.collect(), [Row(id=0, copy=0)])

def test_udf_registration_returns_udf(self):
Expand Down

0 comments on commit 8d2d943

Please sign in to comment.