diff --git a/python/pyspark/sql/connect/dataframe.py b/python/pyspark/sql/connect/dataframe.py index 6fbb57f3ec61d..baac1523c709b 100644 --- a/python/pyspark/sql/connect/dataframe.py +++ b/python/pyspark/sql/connect/dataframe.py @@ -1844,14 +1844,6 @@ def isStreaming(self) -> bool: assert result is not None return result - def _tree_string(self, level: Optional[int] = None) -> str: - query = self._plan.to_proto(self._session.client) - result = self._session.client._analyze( - method="tree_string", plan=query, level=level - ).tree_string - assert result is not None - return result - def printSchema(self, level: Optional[int] = None) -> None: if level: print(self.schema.treeString(level)) diff --git a/python/pyspark/sql/tests/connect/test_connect_basic.py b/python/pyspark/sql/tests/connect/test_connect_basic.py index 74d08424cafcb..598c76a5b25fe 100755 --- a/python/pyspark/sql/tests/connect/test_connect_basic.py +++ b/python/pyspark/sql/tests/connect/test_connect_basic.py @@ -568,7 +568,7 @@ def test_toDF(self): def test_print_schema(self): # SPARK-41216: Test print schema - tree_str = self.connect.sql("SELECT 1 AS X, 2 AS Y")._tree_string() + tree_str = self.connect.sql("SELECT 1 AS X, 2 AS Y").schema.treeString() # root # |-- X: integer (nullable = false) # |-- Y: integer (nullable = false)