Skip to content

Commit 60dd497

Browse files
bogao007HeartSaVioR
authored andcommitted
[SPARK-50978][PYTHON][SS] Fix naming convention for mapStateClient
### What changes were proposed in this pull request? Fix naming convention for mapStateClient. The parameter name should start with lowercase as `mapStateClient` while it's currently `MapStateClient`. ### Why are the changes needed? Didn't follow best practice for parameter naming. ### 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 #49656 from bogao007/mapStateClient-fix. Authored-by: bogao007 <[email protected]> Signed-off-by: Jungtaek Lim <[email protected]>
1 parent f5549d7 commit 60dd497

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/pyspark/sql/streaming/stateful_processor.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -173,10 +173,10 @@ class MapState:
173173

174174
def __init__(
175175
self,
176-
MapStateClient: MapStateClient,
176+
mapStateClient: MapStateClient,
177177
stateName: str,
178178
) -> None:
179-
self._mapStateClient = MapStateClient
179+
self._mapStateClient = mapStateClient
180180
self._stateName = stateName
181181

182182
def exists(self) -> bool:

0 commit comments

Comments
 (0)