diff --git a/python/pyspark/sql/connect/dataframe.py b/python/pyspark/sql/connect/dataframe.py index 6fabab69cf53..b2276c249f6d 100644 --- a/python/pyspark/sql/connect/dataframe.py +++ b/python/pyspark/sql/connect/dataframe.py @@ -1109,6 +1109,15 @@ def writeStream(self, *args: Any, **kwargs: Any) -> None: def toJSON(self, *args: Any, **kwargs: Any) -> None: raise NotImplementedError("toJSON() is not implemented.") + def _repr_html_(self, *args: Any, **kwargs: Any) -> None: + raise NotImplementedError("_repr_html_() is not implemented.") + + def semanticHash(self, *args: Any, **kwargs: Any) -> None: + raise NotImplementedError("semanticHash() is not implemented.") + + def sameSemantics(self, *args: Any, **kwargs: Any) -> None: + raise NotImplementedError("sameSemantics() is not implemented.") + class DataFrameNaFunctions: """Functionality for working with missing data in :class:`DataFrame`. diff --git a/python/pyspark/sql/tests/connect/test_connect_plan_only.py b/python/pyspark/sql/tests/connect/test_connect_plan_only.py index 4d9ee04bf3d2..109702af7e87 100644 --- a/python/pyspark/sql/tests/connect/test_connect_plan_only.py +++ b/python/pyspark/sql/tests/connect/test_connect_plan_only.py @@ -328,6 +328,9 @@ def test_unsupported_functions(self): "toLocalIterator", "checkpoint", "localCheckpoint", + "_repr_html_", + "semanticHash", + "sameSemantics", ): with self.assertRaises(NotImplementedError): getattr(df, f)()