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 e392c5b0470 [SPARK-41923][CONNECT][PYTHON] Add `DataFrame.writeTo` to the unsupported list e392c5b0470 is described below commit e392c5b047008e538173010b32eea6f5331b37f0 Author: Ruifeng Zheng <ruife...@apache.org> AuthorDate: Fri Jan 6 21:28:21 2023 +0900 [SPARK-41923][CONNECT][PYTHON] Add `DataFrame.writeTo` to the unsupported list ### What changes were proposed in this pull request? Add `DataFrame.writeTo` to the unsupported list ### Why are the changes needed? to track the unsupported API ### Does this PR introduce _any_ user-facing change? yes, `NotImplementedError` ### How was this patch tested? added ut Closes #39430 from zhengruifeng/connect_df_disable_dsv2. Authored-by: Ruifeng Zheng <ruife...@apache.org> Signed-off-by: Hyukjin Kwon <gurwls...@apache.org> --- python/pyspark/sql/connect/dataframe.py | 3 +++ python/pyspark/sql/tests/connect/test_connect_basic.py | 1 + 2 files changed, 4 insertions(+) diff --git a/python/pyspark/sql/connect/dataframe.py b/python/pyspark/sql/connect/dataframe.py index 6ca9d36d60a..b1331439cf8 100644 --- a/python/pyspark/sql/connect/dataframe.py +++ b/python/pyspark/sql/connect/dataframe.py @@ -1369,6 +1369,9 @@ class DataFrame: def sameSemantics(self, *args: Any, **kwargs: Any) -> None: raise NotImplementedError("sameSemantics() is not implemented.") + def writeTo(self, *args: Any, **kwargs: Any) -> None: + raise NotImplementedError("writeTo() is not implemented.") + # SparkConnect specific API def offset(self, n: int) -> "DataFrame": """Returns a new :class: `DataFrame` by skipping the first `n` rows. diff --git a/python/pyspark/sql/tests/connect/test_connect_basic.py b/python/pyspark/sql/tests/connect/test_connect_basic.py index 03a45685535..356eb17ee05 100644 --- a/python/pyspark/sql/tests/connect/test_connect_basic.py +++ b/python/pyspark/sql/tests/connect/test_connect_basic.py @@ -1989,6 +1989,7 @@ class SparkConnectBasicTests(SparkConnectSQLTestCase): "_repr_html_", "semanticHash", "sameSemantics", + "writeTo", ): with self.assertRaises(NotImplementedError): getattr(df, f)() --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org