minor comment update clarification

jiateoh · jiateoh · commit cd64f3801c7c · 2025-10-07T10:41:37.000-07:00
diff --git a/python/pyspark/sql/tests/pandas/helper/helper_pandas_transform_with_state.py b/python/pyspark/sql/tests/pandas/helper/helper_pandas_transform_with_state.py
@@ -1840,7 +1840,7 @@ def close(self) -> None:
         pass
 
 
-# A Pandas stateful processor with composite output schema:
+# A Pandas stateful processor with a simple ValueState computation and composite output schema:
 #
 # primitiveValue: StringType
 # listOfPrimitive: ArrayType(StringType)
@@ -1904,7 +1904,7 @@ def handleInputRows(self, key, rows, timerValues) -> Iterator[pd.DataFrame]:
     def close(self) -> None:
         pass
 
-# A Row stateful processor with composite output schema:
+# A Row stateful processor with a simple ValueState computation and composite output schema:
 #
 # primitiveValue: StringType
 # listOfPrimitive: ArrayType(StringType)

Original file line number	Diff line number	Diff line change
`@@ -1840,7 +1840,7 @@ def close(self) -> None:`
`1840`	`1840`	`pass`
`1841`	`1841`
`1842`	`1842`
`1843`		`-# A Pandas stateful processor with composite output schema:`
	`1843`	`+# A Pandas stateful processor with a simple ValueState computation and composite output schema:`
`1844`	`1844`	`#`
`1845`	`1845`	`# primitiveValue: StringType`
`1846`	`1846`	`# listOfPrimitive: ArrayType(StringType)`
`@@ -1904,7 +1904,7 @@ def handleInputRows(self, key, rows, timerValues) -> Iterator[pd.DataFrame]:`
`1904`	`1904`	`def close(self) -> None:`
`1905`	`1905`	`pass`
`1906`	`1906`
`1907`		`-# A Row stateful processor with composite output schema:`
	`1907`	`+# A Row stateful processor with a simple ValueState computation and composite output schema:`
`1908`	`1908`	`#`
`1909`	`1909`	`# primitiveValue: StringType`
`1910`	`1910`	`# listOfPrimitive: ArrayType(StringType)`