Skip to content

Commit c662441

Browse files
bogao007HeartSaVioR
authored andcommitted
[SPARK-50970][PYTHON][SS] Unify naming convention for stateful processor APIs
### What changes were proposed in this pull request? Unify naming convention for stateful processor APIs. ### Why are the changes needed? Following best practice, make TransformWithStateInPandas naming convention consistent across APIs. ### Does this PR introduce _any_ user-facing change? Yes. ### How was this patch tested? Existing unit test. ### Was this patch authored or co-authored using generative AI tooling? No. Closes #49636 from bogao007/python-tws-syntax. Authored-by: bogao007 <[email protected]> Signed-off-by: Jungtaek Lim <[email protected]>
1 parent 5d6bcb9 commit c662441

File tree

3 files changed

+139
-143
lines changed

3 files changed

+139
-143
lines changed

python/pyspark/sql/pandas/group_ops.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -566,8 +566,8 @@ def handle_expired_timers(
566566
statefulProcessorApiClient.set_implicit_key(key_obj)
567567
for pd in statefulProcessor.handleExpiredTimer(
568568
key=key_obj,
569-
timer_values=TimerValues(batch_timestamp, watermark_timestamp),
570-
expired_timer_info=ExpiredTimerInfo(expiry_timestamp),
569+
timerValues=TimerValues(batch_timestamp, watermark_timestamp),
570+
expiredTimerInfo=ExpiredTimerInfo(expiry_timestamp),
571571
):
572572
yield pd
573573
statefulProcessorApiClient.delete_timer(expiry_timestamp)

0 commit comments

Comments
 (0)