Skip to content

Commit de5541a

Browse files
committed
review comments
1 parent 07527aa commit de5541a

File tree

3 files changed

+15
-10
lines changed

3 files changed

+15
-10
lines changed

python/pyspark/sql/connect/dataframe.py

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2208,15 +2208,6 @@ def rdd(self) -> "RDD[Row]":
22082208

22092209
@property
22102210
def queryExecution(self) -> Optional["QueryExecution"]:
2211-
"""
2212-
The queryExecution method allows to introspect information about the actual
2213-
query execution after the successful execution. Accessing this member before
2214-
the query execution has happened will return None.
2215-
2216-
Returns
2217-
-------
2218-
An instance of QueryExecution or None when the value is not set yet.
2219-
"""
22202211
return self._query_execution
22212212

22222213

python/pyspark/sql/dataframe.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6284,6 +6284,19 @@ def toPandas(self) -> "PandasDataFrameLike":
62846284

62856285
@property
62866286
def queryExecution(self) -> Optional["QueryExecution"]:
6287+
"""
6288+
Returns a QueryExecution object after the query was executed.
6289+
6290+
The queryExecution method allows to introspect information about the actual
6291+
query execution after the successful execution. Accessing this member before
6292+
the query execution will return None.
6293+
6294+
.. versionadded:: 4.0.0
6295+
6296+
Returns
6297+
-------
6298+
An instance of QueryExecution or None when the value is not set yet.
6299+
"""
62876300
...
62886301

62896302

python/pyspark/sql/metrics.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,10 @@
1919
from typing import Optional, List, Tuple, Dict, Any, Union, TYPE_CHECKING, Sequence
2020

2121
from pyspark.errors import PySparkValueError
22-
from pyspark.testing.connectutils import have_graphviz
2322

2423
if TYPE_CHECKING:
24+
from pyspark.testing.connectutils import have_graphviz
25+
2526
if have_graphviz:
2627
import graphviz # type: ignore
2728

0 commit comments

Comments
 (0)