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: [email protected]
For additional commands, e-mail: [email protected]
