This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 60dd497a19b7 [SPARK-50978][PYTHON][SS] Fix naming convention for
mapStateClient
60dd497a19b7 is described below
commit 60dd497a19b79659f416f578be0d6e4ab7d629b2
Author: bogao007 <[email protected]>
AuthorDate: Sat Jan 25 13:01:34 2025 +0900
[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]>
---
python/pyspark/sql/streaming/stateful_processor.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/python/pyspark/sql/streaming/stateful_processor.py
b/python/pyspark/sql/streaming/stateful_processor.py
index ba2707ccfb89..d836ec4e2e82 100644
--- a/python/pyspark/sql/streaming/stateful_processor.py
+++ b/python/pyspark/sql/streaming/stateful_processor.py
@@ -173,10 +173,10 @@ class MapState:
def __init__(
self,
- MapStateClient: MapStateClient,
+ mapStateClient: MapStateClient,
stateName: str,
) -> None:
- self._mapStateClient = MapStateClient
+ self._mapStateClient = mapStateClient
self._stateName = stateName
def exists(self) -> bool:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
