This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 944a00db6f83 [SPARK-47224][PS][TESTS] Split `test_split_apply_basic`
and `test_split_apply_adv`
944a00db6f83 is described below
commit 944a00db6f83b076624d5c00cd60dba5667b4e0b
Author: Ruifeng Zheng <[email protected]>
AuthorDate: Thu Feb 29 21:52:34 2024 +0900
[SPARK-47224][PS][TESTS] Split `test_split_apply_basic` and
`test_split_apply_adv`
### What changes were proposed in this pull request?
Split `test_split_apply_basic`/`test_split_apply_adv` and their parity tests
### Why are the changes needed?
it is still slow, split it for testing parallelism
### Does this PR introduce _any_ user-facing change?
no
### How was this patch tested?
ci
### Was this patch authored or co-authored using generative AI tooling?
no
Closes #45332 from zhengruifeng/ps_test_split_apply_basic.
Authored-by: Ruifeng Zheng <[email protected]>
Signed-off-by: Hyukjin Kwon <[email protected]>
---
dev/sparktestsupport/modules.py | 16 ++++++++++++----
...t_apply_basic.py => test_parity_split_apply_count.py} | 8 ++++----
...lit_apply_adv.py => test_parity_split_apply_first.py} | 8 ++++----
...plit_apply_adv.py => test_parity_split_apply_last.py} | 8 ++++----
...plit_apply_adv.py => test_parity_split_apply_skew.py} | 8 ++++----
...split_apply_adv.py => test_parity_split_apply_std.py} | 8 ++++----
...split_apply_adv.py => test_parity_split_apply_var.py} | 8 ++++----
...st_split_apply_basic.py => test_split_apply_count.py} | 10 +++++-----
...st_split_apply_basic.py => test_split_apply_first.py} | 10 +++++-----
...est_split_apply_basic.py => test_split_apply_last.py} | 8 ++++----
...{test_split_apply_adv.py => test_split_apply_skew.py} | 10 +++++-----
.../{test_split_apply_adv.py => test_split_apply_std.py} | 10 +++++-----
.../{test_split_apply_adv.py => test_split_apply_var.py} | 10 +++++-----
13 files changed, 65 insertions(+), 57 deletions(-)
diff --git a/dev/sparktestsupport/modules.py b/dev/sparktestsupport/modules.py
index 629e74650bea..b2c64a8242de 100644
--- a/dev/sparktestsupport/modules.py
+++ b/dev/sparktestsupport/modules.py
@@ -904,9 +904,13 @@ pyspark_pandas_slow = Module(
"pyspark.pandas.tests.groupby.test_rank",
"pyspark.pandas.tests.groupby.test_size",
"pyspark.pandas.tests.groupby.test_split_apply",
- "pyspark.pandas.tests.groupby.test_split_apply_adv",
- "pyspark.pandas.tests.groupby.test_split_apply_basic",
+ "pyspark.pandas.tests.groupby.test_split_apply_count",
+ "pyspark.pandas.tests.groupby.test_split_apply_first",
+ "pyspark.pandas.tests.groupby.test_split_apply_last",
"pyspark.pandas.tests.groupby.test_split_apply_min_max",
+ "pyspark.pandas.tests.groupby.test_split_apply_skew",
+ "pyspark.pandas.tests.groupby.test_split_apply_std",
+ "pyspark.pandas.tests.groupby.test_split_apply_var",
"pyspark.pandas.tests.groupby.test_stat",
"pyspark.pandas.tests.groupby.test_stat_adv",
"pyspark.pandas.tests.groupby.test_stat_ddof",
@@ -1180,9 +1184,13 @@ pyspark_pandas_connect_part1 = Module(
"pyspark.pandas.tests.connect.groupby.test_parity_cumulative",
"pyspark.pandas.tests.connect.groupby.test_parity_missing_data",
"pyspark.pandas.tests.connect.groupby.test_parity_split_apply",
- "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_adv",
- "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_basic",
+ "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_count",
+ "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_first",
+ "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_last",
"pyspark.pandas.tests.connect.groupby.test_parity_split_apply_min_max",
+ "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_skew",
+ "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_std",
+ "pyspark.pandas.tests.connect.groupby.test_parity_split_apply_var",
"pyspark.pandas.tests.connect.series.test_parity_datetime",
"pyspark.pandas.tests.connect.series.test_parity_string_ops_adv",
"pyspark.pandas.tests.connect.series.test_parity_string_ops_basic",
diff --git
a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_basic.py
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_count.py
similarity index 87%
rename from
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_basic.py
rename to
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_count.py
index 2964213ab484..3e7931d1b5a0 100644
---
a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_basic.py
+++
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_count.py
@@ -16,13 +16,13 @@
#
import unittest
-from pyspark.pandas.tests.groupby.test_split_apply_basic import
GroupbySplitApplyBasicMixin
+from pyspark.pandas.tests.groupby.test_split_apply_count import
GroupbySplitApplyCountMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils
-class GroupbySplitApplyBasicParityTests(
- GroupbySplitApplyBasicMixin,
+class GroupbySplitApplyCountParityTests(
+ GroupbySplitApplyCountMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@@ -30,7 +30,7 @@ class GroupbySplitApplyBasicParityTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_basic
import * # noqa
+ from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_count
import * # noqa
try:
import xmlrunner # type: ignore[import]
diff --git
a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_first.py
similarity index 87%
copy from
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
copy to
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_first.py
index f8ddd8b8c9ab..c15f57da1cb7 100644
--- a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
+++
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_first.py
@@ -16,13 +16,13 @@
#
import unittest
-from pyspark.pandas.tests.groupby.test_split_apply_adv import
GroupbySplitApplyAdvMixin
+from pyspark.pandas.tests.groupby.test_split_apply_first import
GroupbySplitApplyFirstMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils
-class GroupbySplitApplyAdvParityTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplyFirstParityTests(
+ GroupbySplitApplyFirstMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@@ -30,7 +30,7 @@ class GroupbySplitApplyAdvParityTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_adv
import * # noqa
+ from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_first
import * # noqa
try:
import xmlrunner # type: ignore[import]
diff --git
a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_last.py
similarity index 87%
copy from
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
copy to
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_last.py
index f8ddd8b8c9ab..474e6d01a8a2 100644
--- a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
+++
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_last.py
@@ -16,13 +16,13 @@
#
import unittest
-from pyspark.pandas.tests.groupby.test_split_apply_adv import
GroupbySplitApplyAdvMixin
+from pyspark.pandas.tests.groupby.test_split_apply_last import
GroupbySplitApplyLastMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils
-class GroupbySplitApplyAdvParityTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplyLastParityTests(
+ GroupbySplitApplyLastMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@@ -30,7 +30,7 @@ class GroupbySplitApplyAdvParityTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_adv
import * # noqa
+ from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_last
import * # noqa
try:
import xmlrunner # type: ignore[import]
diff --git
a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_skew.py
similarity index 87%
copy from
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
copy to
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_skew.py
index f8ddd8b8c9ab..746480a7fe9d 100644
--- a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
+++
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_skew.py
@@ -16,13 +16,13 @@
#
import unittest
-from pyspark.pandas.tests.groupby.test_split_apply_adv import
GroupbySplitApplyAdvMixin
+from pyspark.pandas.tests.groupby.test_split_apply_skew import
GroupbySplitApplySkewMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils
-class GroupbySplitApplyAdvParityTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplySkewParityTests(
+ GroupbySplitApplySkewMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@@ -30,7 +30,7 @@ class GroupbySplitApplyAdvParityTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_adv
import * # noqa
+ from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_skew
import * # noqa
try:
import xmlrunner # type: ignore[import]
diff --git
a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_std.py
similarity index 87%
copy from
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
copy to
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_std.py
index f8ddd8b8c9ab..cd7457ed4103 100644
--- a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
+++ b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_std.py
@@ -16,13 +16,13 @@
#
import unittest
-from pyspark.pandas.tests.groupby.test_split_apply_adv import
GroupbySplitApplyAdvMixin
+from pyspark.pandas.tests.groupby.test_split_apply_std import
GroupbySplitApplyStdMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils
-class GroupbySplitApplyAdvParityTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplyStdParityTests(
+ GroupbySplitApplyStdMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@@ -30,7 +30,7 @@ class GroupbySplitApplyAdvParityTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_adv
import * # noqa
+ from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_std
import * # noqa
try:
import xmlrunner # type: ignore[import]
diff --git
a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_var.py
similarity index 87%
rename from
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
rename to
python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_var.py
index f8ddd8b8c9ab..642e84dee839 100644
--- a/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_adv.py
+++ b/python/pyspark/pandas/tests/connect/groupby/test_parity_split_apply_var.py
@@ -16,13 +16,13 @@
#
import unittest
-from pyspark.pandas.tests.groupby.test_split_apply_adv import
GroupbySplitApplyAdvMixin
+from pyspark.pandas.tests.groupby.test_split_apply_var import
GroupbySplitApplyVarMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils
-class GroupbySplitApplyAdvParityTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplyVarParityTests(
+ GroupbySplitApplyVarMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@@ -30,7 +30,7 @@ class GroupbySplitApplyAdvParityTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_adv
import * # noqa
+ from pyspark.pandas.tests.connect.groupby.test_parity_split_apply_var
import * # noqa
try:
import xmlrunner # type: ignore[import]
diff --git a/python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
b/python/pyspark/pandas/tests/groupby/test_split_apply_count.py
similarity index 85%
copy from python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
copy to python/pyspark/pandas/tests/groupby/test_split_apply_count.py
index 17c6179d19ac..7d13fe04c63e 100644
--- a/python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
+++ b/python/pyspark/pandas/tests/groupby/test_split_apply_count.py
@@ -21,16 +21,16 @@ from pyspark.testing.sqlutils import SQLTestUtils
from pyspark.pandas.tests.groupby.test_split_apply import
GroupbySplitApplyTestingFuncMixin
-class GroupbySplitApplyBasicMixin(GroupbySplitApplyTestingFuncMixin):
+class GroupbySplitApplyCountMixin(GroupbySplitApplyTestingFuncMixin):
def test_split_apply_combine_on_series(self):
funcs = [
- ((True, False), ["count", "first", "last"]),
+ ((True, False), ["count"]),
]
self._test_split_apply_func(funcs)
-class GroupbySplitApplyBasicTests(
- GroupbySplitApplyBasicMixin,
+class GroupbySplitApplyCountTests(
+ GroupbySplitApplyCountMixin,
PandasOnSparkTestCase,
SQLTestUtils,
):
@@ -38,7 +38,7 @@ class GroupbySplitApplyBasicTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.groupby.test_split_apply_basic import * # noqa:
F401
+ from pyspark.pandas.tests.groupby.test_split_apply_count import * # noqa:
F401
try:
import xmlrunner
diff --git a/python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
b/python/pyspark/pandas/tests/groupby/test_split_apply_first.py
similarity index 85%
copy from python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
copy to python/pyspark/pandas/tests/groupby/test_split_apply_first.py
index 17c6179d19ac..cb44b31e8a06 100644
--- a/python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
+++ b/python/pyspark/pandas/tests/groupby/test_split_apply_first.py
@@ -21,16 +21,16 @@ from pyspark.testing.sqlutils import SQLTestUtils
from pyspark.pandas.tests.groupby.test_split_apply import
GroupbySplitApplyTestingFuncMixin
-class GroupbySplitApplyBasicMixin(GroupbySplitApplyTestingFuncMixin):
+class GroupbySplitApplyFirstMixin(GroupbySplitApplyTestingFuncMixin):
def test_split_apply_combine_on_series(self):
funcs = [
- ((True, False), ["count", "first", "last"]),
+ ((True, False), ["first"]),
]
self._test_split_apply_func(funcs)
-class GroupbySplitApplyBasicTests(
- GroupbySplitApplyBasicMixin,
+class GroupbySplitApplyFirstTests(
+ GroupbySplitApplyFirstMixin,
PandasOnSparkTestCase,
SQLTestUtils,
):
@@ -38,7 +38,7 @@ class GroupbySplitApplyBasicTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.groupby.test_split_apply_basic import * # noqa:
F401
+ from pyspark.pandas.tests.groupby.test_split_apply_first import * # noqa:
F401
try:
import xmlrunner
diff --git a/python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
b/python/pyspark/pandas/tests/groupby/test_split_apply_last.py
similarity index 85%
rename from python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
rename to python/pyspark/pandas/tests/groupby/test_split_apply_last.py
index 17c6179d19ac..4d9f3628634a 100644
--- a/python/pyspark/pandas/tests/groupby/test_split_apply_basic.py
+++ b/python/pyspark/pandas/tests/groupby/test_split_apply_last.py
@@ -21,16 +21,16 @@ from pyspark.testing.sqlutils import SQLTestUtils
from pyspark.pandas.tests.groupby.test_split_apply import
GroupbySplitApplyTestingFuncMixin
-class GroupbySplitApplyBasicMixin(GroupbySplitApplyTestingFuncMixin):
+class GroupbySplitApplyLastMixin(GroupbySplitApplyTestingFuncMixin):
def test_split_apply_combine_on_series(self):
funcs = [
- ((True, False), ["count", "first", "last"]),
+ ((True, False), ["last"]),
]
self._test_split_apply_func(funcs)
class GroupbySplitApplyBasicTests(
- GroupbySplitApplyBasicMixin,
+ GroupbySplitApplyLastMixin,
PandasOnSparkTestCase,
SQLTestUtils,
):
@@ -38,7 +38,7 @@ class GroupbySplitApplyBasicTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.groupby.test_split_apply_basic import * # noqa:
F401
+ from pyspark.pandas.tests.groupby.test_split_apply_last import * # noqa:
F401
try:
import xmlrunner
diff --git a/python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
b/python/pyspark/pandas/tests/groupby/test_split_apply_skew.py
similarity index 84%
copy from python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
copy to python/pyspark/pandas/tests/groupby/test_split_apply_skew.py
index abce6d5ed4f0..8af555bdbb73 100644
--- a/python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
+++ b/python/pyspark/pandas/tests/groupby/test_split_apply_skew.py
@@ -21,16 +21,16 @@ from pyspark.testing.sqlutils import SQLTestUtils
from pyspark.pandas.tests.groupby.test_split_apply import
GroupbySplitApplyTestingFuncMixin
-class GroupbySplitApplyAdvMixin(GroupbySplitApplyTestingFuncMixin):
+class GroupbySplitApplySkewMixin(GroupbySplitApplyTestingFuncMixin):
def test_split_apply_combine_on_series(self):
funcs = [
- ((False, False), ["var", "std", "skew"]),
+ ((False, False), ["skew"]),
]
self._test_split_apply_func(funcs)
-class GroupbySplitApplyAdvTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplySkewTests(
+ GroupbySplitApplySkewMixin,
PandasOnSparkTestCase,
SQLTestUtils,
):
@@ -38,7 +38,7 @@ class GroupbySplitApplyAdvTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.groupby.test_split_apply_adv import * # noqa:
F401
+ from pyspark.pandas.tests.groupby.test_split_apply_skew import * # noqa:
F401
try:
import xmlrunner
diff --git a/python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
b/python/pyspark/pandas/tests/groupby/test_split_apply_std.py
similarity index 85%
copy from python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
copy to python/pyspark/pandas/tests/groupby/test_split_apply_std.py
index abce6d5ed4f0..c215478bb837 100644
--- a/python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
+++ b/python/pyspark/pandas/tests/groupby/test_split_apply_std.py
@@ -21,16 +21,16 @@ from pyspark.testing.sqlutils import SQLTestUtils
from pyspark.pandas.tests.groupby.test_split_apply import
GroupbySplitApplyTestingFuncMixin
-class GroupbySplitApplyAdvMixin(GroupbySplitApplyTestingFuncMixin):
+class GroupbySplitApplyStdMixin(GroupbySplitApplyTestingFuncMixin):
def test_split_apply_combine_on_series(self):
funcs = [
- ((False, False), ["var", "std", "skew"]),
+ ((False, False), ["std"]),
]
self._test_split_apply_func(funcs)
-class GroupbySplitApplyAdvTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplyStdTests(
+ GroupbySplitApplyStdMixin,
PandasOnSparkTestCase,
SQLTestUtils,
):
@@ -38,7 +38,7 @@ class GroupbySplitApplyAdvTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.groupby.test_split_apply_adv import * # noqa:
F401
+ from pyspark.pandas.tests.groupby.test_split_apply_std import * # noqa:
F401
try:
import xmlrunner
diff --git a/python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
b/python/pyspark/pandas/tests/groupby/test_split_apply_var.py
similarity index 85%
rename from python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
rename to python/pyspark/pandas/tests/groupby/test_split_apply_var.py
index abce6d5ed4f0..314f7b944957 100644
--- a/python/pyspark/pandas/tests/groupby/test_split_apply_adv.py
+++ b/python/pyspark/pandas/tests/groupby/test_split_apply_var.py
@@ -21,16 +21,16 @@ from pyspark.testing.sqlutils import SQLTestUtils
from pyspark.pandas.tests.groupby.test_split_apply import
GroupbySplitApplyTestingFuncMixin
-class GroupbySplitApplyAdvMixin(GroupbySplitApplyTestingFuncMixin):
+class GroupbySplitApplyVarMixin(GroupbySplitApplyTestingFuncMixin):
def test_split_apply_combine_on_series(self):
funcs = [
- ((False, False), ["var", "std", "skew"]),
+ ((False, False), ["var"]),
]
self._test_split_apply_func(funcs)
-class GroupbySplitApplyAdvTests(
- GroupbySplitApplyAdvMixin,
+class GroupbySplitApplyVarTests(
+ GroupbySplitApplyVarMixin,
PandasOnSparkTestCase,
SQLTestUtils,
):
@@ -38,7 +38,7 @@ class GroupbySplitApplyAdvTests(
if __name__ == "__main__":
- from pyspark.pandas.tests.groupby.test_split_apply_adv import * # noqa:
F401
+ from pyspark.pandas.tests.groupby.test_split_apply_var import * # noqa:
F401
try:
import xmlrunner
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
