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
