diff options
author | Cheng Lian <lian@databricks.com> | 2015-12-09 23:30:42 +0800 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-12-09 23:30:42 +0800 |
commit | 6e1c55eac4849669e119ce0d51f6d051830deb9f (patch) | |
tree | 4d8286eb371c2de27cc374ed55749c2830add681 /python/pyspark/sql/dataframe.py | |
parent | a113216865fd45ea39ae8f104e784af2cf667dcf (diff) | |
download | spark-6e1c55eac4849669e119ce0d51f6d051830deb9f.tar.gz spark-6e1c55eac4849669e119ce0d51f6d051830deb9f.tar.bz2 spark-6e1c55eac4849669e119ce0d51f6d051830deb9f.zip |
[SPARK-12012][SQL] Show more comprehensive PhysicalRDD metadata when visualizing SQL query plan
This PR adds a `private[sql]` method `metadata` to `SparkPlan`, which can be used to describe detail information about a physical plan during visualization. Specifically, this PR uses this method to provide details of `PhysicalRDD`s translated from a data source relation. For example, a `ParquetRelation` converted from Hive metastore table `default.psrc` is now shown as the following screenshot:
![image](https://cloud.githubusercontent.com/assets/230655/11526657/e10cb7e6-9916-11e5-9afa-f108932ec890.png)
And here is the screenshot for a regular `ParquetRelation` (not converted from Hive metastore table) loaded from a really long path:
![output](https://cloud.githubusercontent.com/assets/230655/11680582/37c66460-9e94-11e5-8f50-842db5309d5a.png)
Author: Cheng Lian <lian@databricks.com>
Closes #10004 from liancheng/spark-12012.physical-rdd-metadata.
Diffstat (limited to 'python/pyspark/sql/dataframe.py')
-rw-r--r-- | python/pyspark/sql/dataframe.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/sql/dataframe.py b/python/pyspark/sql/dataframe.py index 746bb55e14..78ab475eb4 100644 --- a/python/pyspark/sql/dataframe.py +++ b/python/pyspark/sql/dataframe.py @@ -213,7 +213,7 @@ class DataFrame(object): >>> df.explain() == Physical Plan == - Scan PhysicalRDD[age#0,name#1] + Scan ExistingRDD[age#0,name#1] >>> df.explain(True) == Parsed Logical Plan == |