This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 32dd7534365 [SPARK-40522][BUILD] Upgrade `kafka` to 3.2.3
add c22ddbea6b3 [SPARK-40435][SS][PYTHON] Add test suites for
applyInPandasWithState in PySpark
No new revisions were added by this update.
Summary of changes:
dev/sparktestsupport/modules.py | 1 +
.../tests/test_pandas_grouped_map_with_state.py | 103 +++
.../apache/spark/sql/IntegratedUDFTestUtils.scala | 73 +-
.../org/apache/spark/sql/SQLQueryTestSuite.scala | 8 +-
.../sql/errors/QueryCompilationErrorsSuite.scala | 4 +-
.../sql/execution/python/PythonUDFSuite.scala | 2 +-
...pGroupsInPandasWithStateDistributionSuite.scala | 115 ++++
.../FlatMapGroupsInPandasWithStateSuite.scala | 741 +++++++++++++++++++++
.../sql/streaming/continuous/ContinuousSuite.scala | 2 +-
9 files changed, 1035 insertions(+), 14 deletions(-)
create mode 100644
python/pyspark/sql/tests/test_pandas_grouped_map_with_state.py
create mode 100644
sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsInPandasWithStateDistributionSuite.scala
create mode 100644
sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsInPandasWithStateSuite.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
