Skip to content

Commit

Permalink
reformat python
Browse files Browse the repository at this point in the history
  • Loading branch information
dtenedor committed Nov 13, 2023
1 parent 768096d commit 20e6d1e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
3 changes: 1 addition & 2 deletions python/pyspark/sql/tests/test_udtf.py
Original file line number Diff line number Diff line change
Expand Up @@ -2512,8 +2512,7 @@ def terminate(self):
ORDER BY ALL
"""
),
[Row(id_divided_by_ten=0, total=4),
Row(id_divided_by_ten=1, total=4)],
[Row(id_divided_by_ten=0, total=4), Row(id_divided_by_ten=1, total=4)],
)


Expand Down
1 change: 1 addition & 0 deletions python/pyspark/sql/udtf.py
Original file line number Diff line number Diff line change
Expand Up @@ -131,6 +131,7 @@ class SkipRestOfInputTableException(Exception):
consuming rows from the current partition of the input table. Then the UDTF's 'terminate'
method runs (if any).
"""

pass


Expand Down

0 comments on commit 20e6d1e

Please sign in to comment.