Update API naming

apache · Jan 24, 2025 · 2e7e0da · 2e7e0da
1 parent 2b657fe
commit 2e7e0da
Show file tree

Hide file tree

Showing 3 changed files with 139 additions and 139 deletions.
diff --git a/python/pyspark/sql/pandas/group_ops.py b/python/pyspark/sql/pandas/group_ops.py
@@ -566,8 +566,8 @@ def handle_expired_timers(
                     statefulProcessorApiClient.set_implicit_key(key_obj)
                     for pd in statefulProcessor.handleExpiredTimer(
                         key=key_obj,
-                        timer_values=TimerValues(batch_timestamp, watermark_timestamp),
-                        expired_timer_info=ExpiredTimerInfo(expiry_timestamp),
+                        timerValues=TimerValues(batch_timestamp, watermark_timestamp),
+                        expiredTimerInfo=ExpiredTimerInfo(expiry_timestamp),
                     ):
                         yield pd
                     statefulProcessorApiClient.delete_timer(expiry_timestamp)