You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ru...@apache.org on 2025/10/24 09:26:41 UTC
(spark) branch master updated (2b2a2a2e18e7 -> a94e709dcbab)
This is an automated email from the ASF dual-hosted git repository.
ruifengz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 2b2a2a2e18e7 [SPARK-54004][SQL] Fix uncaching table by name without cascading
add a94e709dcbab [SPARK-53986][PYTHON][SS][TESTS] Reorganize Python streaming TWS test
No new revisions were added by this update.
Summary of changes:
dev/sparktestsupport/modules.py | 18 +-
.../tests/connect/pandas/streaming}/__init__.py | 0
.../test_parity_pandas_grouped_map_with_state.py | 2 +-
.../test_parity_pandas_transform_with_state.py | 4 +-
..._pandas_transform_with_state_state_variable.py} | 18 +-
.../streaming/test_parity_transform_with_state.py} | 4 +-
..._parity_transform_with_state_state_variable.py} | 20 +-
.../sql/tests/pandas/streaming}/__init__.py | 0
.../test_pandas_transform_with_state.py | 814 +---------------
...st_pandas_transform_with_state_checkpoint_v2.py | 19 +-
...t_pandas_transform_with_state_state_variable.py | 1018 ++++++++++++++++++++
...orm_with_state_state_variable_checkpoint_v2.py} | 29 +-
.../pandas/streaming/test_transform_with_state.py | 70 ++
.../test_transform_with_state_checkpoint_v2.py} | 19 +-
.../test_transform_with_state_state_variable.py | 74 ++
...orm_with_state_state_variable_checkpoint_v2.py} | 29 +-
16 files changed, 1217 insertions(+), 921 deletions(-)
copy {examples/src/main/python => python/pyspark/sql/tests/connect/pandas/streaming}/__init__.py (100%)
rename python/pyspark/sql/tests/connect/pandas/{ => streaming}/test_parity_pandas_grouped_map_with_state.py (91%)
copy python/pyspark/sql/tests/connect/pandas/{ => streaming}/test_parity_pandas_transform_with_state.py (91%)
copy python/pyspark/sql/tests/connect/pandas/{test_parity_pandas_transform_with_state.py => streaming/test_parity_pandas_transform_with_state_state_variable.py} (73%)
rename python/pyspark/sql/tests/connect/{streaming/test_parity_transform_with_state_pyspark.py => pandas/streaming/test_parity_transform_with_state.py} (92%)
rename python/pyspark/sql/tests/connect/pandas/{test_parity_pandas_transform_with_state.py => streaming/test_parity_transform_with_state_state_variable.py} (70%)
copy {examples/src/main/python => python/pyspark/sql/tests/pandas/streaming}/__init__.py (100%)
rename python/pyspark/sql/tests/pandas/{ => streaming}/test_pandas_transform_with_state.py (64%)
copy python/pyspark/sql/tests/pandas/{ => streaming}/test_pandas_transform_with_state_checkpoint_v2.py (71%)
create mode 100644 python/pyspark/sql/tests/pandas/streaming/test_pandas_transform_with_state_state_variable.py
copy python/pyspark/sql/tests/pandas/{test_pandas_transform_with_state_checkpoint_v2.py => streaming/test_pandas_transform_with_state_state_variable_checkpoint_v2.py} (58%)
create mode 100644 python/pyspark/sql/tests/pandas/streaming/test_transform_with_state.py
copy python/pyspark/sql/tests/pandas/{test_pandas_transform_with_state_checkpoint_v2.py => streaming/test_transform_with_state_checkpoint_v2.py} (71%)
create mode 100644 python/pyspark/sql/tests/pandas/streaming/test_transform_with_state_state_variable.py
rename python/pyspark/sql/tests/pandas/{test_pandas_transform_with_state_checkpoint_v2.py => streaming/test_transform_with_state_state_variable_checkpoint_v2.py} (58%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org