Skip to content

[SPARK-52889][PYTHON] Implement the current_time function in PySpark #51584

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 11 commits into from
Closed

[SPARK-52889][PYTHON] Implement the current_time function in PySpark #51584

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
277724c
Initial commit
uros-db Jul 20, 2025
8f51f9a
Merge branch 'apache:master' into python-current_time
uros-db Jul 27, 2025
c2c1e60
current_time
uros-db Jul 27, 2025
543af90
Update test
uros-db Jul 27, 2025
c51bc9a
Precision
uros-db Jul 27, 2025
d4c6859
Connect
uros-db Jul 27, 2025
bb58695
Refactor
uros-db Jul 27, 2025
989686a
Update examples
uros-db Jul 28, 2025
20547a9
Fix precision
uros-db Jul 28, 2025
1674d77
Merge branch 'master' into python-current_time
uros-db Jul 28, 2025
d13a0dd
Merge branch 'master' into python-current_time
uros-db Jul 28, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update test
  • Loading branch information
@uros-db
uros-db committed Jul 27, 2025
commit 543af90da459f090fa09052196cd7cecd7df9d43
1 change: 1 addition & 0 deletions python/pyspark/sql/tests/test_functions.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1781,6 +1781,7 @@ def test_non_deterministic_with_seed(self):
self.assertEqual(res[0][i * 2], res[0][i * 2 + 1])

def test_current_time(self):
# SPARK-52889: test the current_time function.
df = self.spark.range(1).select(F.current_time())
self.assertIsInstance(df.first()[0], datetime.time)
self.assertEqual(df.schema.names[0], "current_time()")
Expand Down