This is an automated email from the ASF dual-hosted git repository.

kabhwan pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/branch-4.0 by this push:
     new 338754e35052 [SPARK-50978][PYTHON][SS] Fix naming convention for 
mapStateClient
338754e35052 is described below

commit 338754e3505227df2c0279df495c2df7a8cb68ed
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]>
    (cherry picked from commit 60dd497a19b79659f416f578be0d6e4ab7d629b2)
    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]

Reply via email to