Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 6 additions & 5 deletions python/pyspark/pandas/tests/connect/frame/test_parity_attrs.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,16 +16,17 @@
#
import unittest

from pyspark import pandas as ps
from pyspark.pandas.tests.frame.test_attrs import FrameAttrsMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParityAttrsTests(FrameAttrsMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
@property
def psdf(self):
return ps.from_pandas(self.pdf)
class FrameParityAttrsTests(
FrameAttrsMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


if __name__ == "__main__":
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParityAxisTests(FrameAxisMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class FrameParityAxisTests(
FrameAxisMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class FrameParityConstructorTests(
FrameConstructorMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
FrameConstructorMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,18 +16,17 @@
#
import unittest

from pyspark import pandas as ps
from pyspark.pandas.tests.frame.test_conversion import FrameConversionMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParityConversionTests(
FrameConversionMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
FrameConversionMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@property
def psdf(self):
return ps.from_pandas(self.pdf)
pass


if __name__ == "__main__":
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,18 +16,17 @@
#
import unittest

from pyspark import pandas as ps
from pyspark.pandas.tests.frame.test_reindexing import FrameReindexingMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParityReindexingTests(
FrameReindexingMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
FrameReindexingMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@property
def psdf(self):
return ps.from_pandas(self.pdf)
pass


if __name__ == "__main__":
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParityReshapingTests(FrameReshapingMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class FrameParityReshapingTests(
FrameReshapingMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
11 changes: 6 additions & 5 deletions python/pyspark/pandas/tests/connect/frame/test_parity_spark.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,16 +16,17 @@
#
import unittest

from pyspark import pandas as ps
from pyspark.pandas.tests.frame.test_spark import FrameSparkMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParitySparkTests(FrameSparkMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
@property
def psdf(self):
return ps.from_pandas(self.pdf)
class FrameParitySparkTests(
FrameSparkMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


if __name__ == "__main__":
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,18 +16,17 @@
#
import unittest

from pyspark import pandas as ps
from pyspark.pandas.tests.frame.test_time_series import FrameTimeSeriesMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParityTimeSeriesTests(
FrameTimeSeriesMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
FrameTimeSeriesMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@property
def psdf(self):
return ps.from_pandas(self.pdf)
pass


if __name__ == "__main__":
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,16 +16,17 @@
#
import unittest

from pyspark import pandas as ps
from pyspark.pandas.tests.frame.test_truncate import FrameTruncateMixin
from pyspark.testing.connectutils import ReusedConnectTestCase
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class FrameParityTruncateTests(FrameTruncateMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
@property
def psdf(self):
return ps.from_pandas(self.pdf)
class FrameParityTruncateTests(
FrameTruncateMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


if __name__ == "__main__":
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class GroupbyParityAggregateTests(
GroupbyAggregateMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
GroupbyAggregateMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class GroupbyParityApplyFuncTests(
GroupbyApplyFuncMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
GroupbyApplyFuncMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
@unittest.skip("Test depends on SparkContext which is not supported from Spark Connect.")
def test_apply_with_side_effect(self):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class GroupbyParityCumulativeTests(
GroupbyCumulativeMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
GroupbyCumulativeMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class GroupbyParityDescribeTests(
GroupbyDescribeMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
GroupbyDescribeMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,10 @@


class GroupByParityTests(
GroupByTestsMixin, PandasOnSparkTestUtils, TestUtils, ReusedConnectTestCase
GroupByTestsMixin,
PandasOnSparkTestUtils,
TestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class GroupbyParityHeadTailTests(
GroupbyHeadTailMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
GroupbyHeadTailMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class GroupbyParityIndexTests(GroupbyIndexMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class GroupbyParityIndexTests(
GroupbyIndexMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class GroupbyParityMissingDataTests(
GroupbyMissingDataMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
GroupbyMissingDataMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class SeriesParityAllAnyTests(SeriesAllAnyMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class SeriesParityAllAnyTests(
SeriesAllAnyMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class SeriesParityArgOpsTests(SeriesArgOpsMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class SeriesParityArgOpsTests(
SeriesArgOpsMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class SeriesParityArgOpsTests(SeriesAsOfMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class SeriesParityArgOpsTests(
SeriesAsOfMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class SeriesParityAsTypeTests(SeriesAsTypeMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class SeriesParityAsTypeTests(
SeriesAsTypeMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class SeriesParityComputeTests(SeriesComputeMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class SeriesParityComputeTests(
SeriesComputeMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class SeriesParityConversionTests(
SeriesConversionMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
SeriesConversionMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class SeriesParityCumulativeTests(
SeriesCumulativeMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
SeriesCumulativeMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class SeriesParityIndexTests(SeriesIndexMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class SeriesParityIndexTests(
SeriesIndexMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@


class SeriesParityMissingDataTests(
SeriesMissingDataMixin, PandasOnSparkTestUtils, ReusedConnectTestCase
SeriesMissingDataMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@
from pyspark.testing.pandasutils import PandasOnSparkTestUtils


class SeriesParityTests(SeriesTestsMixin, PandasOnSparkTestUtils, ReusedConnectTestCase):
class SeriesParityTests(
SeriesTestsMixin,
PandasOnSparkTestUtils,
ReusedConnectTestCase,
):
pass


Expand Down
Loading