diff options
| author | Takeshi Yamamuro <yamamuro@apache.org> | 2017-04-20 19:40:21 -0700 |
|---|---|---|
| committer | Xiao Li <gatorsmile@gmail.com> | 2017-04-20 19:40:21 -0700 |
| commit | 48d760d028dd73371f99d084c4195dbc4dda5267 (patch) | |
| tree | 12c6b6d7a84e157ab681c3616ea59f6d5f746d3f /sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala | |
| parent | 760c8d088df1d35d7b8942177d47bc1677daf143 (diff) | |
| download | spark-48d760d028dd73371f99d084c4195dbc4dda5267.tar.gz spark-48d760d028dd73371f99d084c4195dbc4dda5267.tar.bz2 spark-48d760d028dd73371f99d084c4195dbc4dda5267.zip | |
[SPARK-20281][SQL] Print the identical Range parameters of SparkContext APIs and SQL in explain
## What changes were proposed in this pull request?
This pr modified code to print the identical `Range` parameters of SparkContext APIs and SQL in `explain` output. In the current master, they internally use `defaultParallelism` for `splits` by default though, they print different strings in explain output;
```
scala> spark.range(4).explain
== Physical Plan ==
*Range (0, 4, step=1, splits=Some(8))
scala> sql("select * from range(4)").explain
== Physical Plan ==
*Range (0, 4, step=1, splits=None)
```
## How was this patch tested?
Added tests in `SQLQuerySuite` and modified some results in the existing tests.
Author: Takeshi Yamamuro <yamamuro@apache.org>
Closes #17670 from maropu/SPARK-20281.
Diffstat (limited to 'sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala')
0 files changed, 0 insertions, 0 deletions