diff --git a/python/pyspark/pandas/base.py b/python/pyspark/pandas/base.py index 1cb17de89e8dd..ef0b51f757d81 100644 --- a/python/pyspark/pandas/base.py +++ b/python/pyspark/pandas/base.py @@ -505,7 +505,7 @@ def empty(self) -> bool: >>> ps.DataFrame({}, index=list('abc')).index.empty False """ - return self._internal.resolved_copy.spark_frame.rdd.isEmpty() + return self._internal.resolved_copy.spark_frame.isEmpty() @property def hasnans(self) -> bool: diff --git a/python/pyspark/pandas/tests/series/test_series.py b/python/pyspark/pandas/tests/series/test_series.py index 136d905eb494b..aa147aa75cfcb 100644 --- a/python/pyspark/pandas/tests/series/test_series.py +++ b/python/pyspark/pandas/tests/series/test_series.py @@ -113,6 +113,8 @@ def test_empty_series(self): self.assert_eq(ps.from_pandas(pser_a), pser_a) self.assert_eq(ps.from_pandas(pser_b), pser_b) + self.assertTrue(pser_a.empty) + def test_all_null_series(self): pser_a = pd.Series([None, None, None], dtype="float64") pser_b = pd.Series([None, None, None], dtype="str")