diff options
| author | Yin Huai <yhuai@databricks.com> | 2015-08-12 21:24:15 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-08-12 21:24:15 -0700 |
| commit | 2278219054314f1d31ffc358a59aa5067f9f5de9 (patch) | |
| tree | dbc8355c5f048b556f5e9cb688ef7081af90a61d /sbin/start-slaves.sh | |
| parent | 2fb4901b71cee65d40a43e61e3f4411c30cdefc3 (diff) | |
| download | spark-2278219054314f1d31ffc358a59aa5067f9f5de9.tar.gz spark-2278219054314f1d31ffc358a59aa5067f9f5de9.tar.bz2 spark-2278219054314f1d31ffc358a59aa5067f9f5de9.zip | |
[SPARK-9920] [SQL] The simpleString of TungstenAggregate does not show its output
https://issues.apache.org/jira/browse/SPARK-9920
Taking `sqlContext.sql("select i, sum(j1) as sum from testAgg group by i").explain()` as an example, the output of our current master is
```
== Physical Plan ==
TungstenAggregate(key=[i#0], value=[(sum(cast(j1#1 as bigint)),mode=Final,isDistinct=false)]
TungstenExchange hashpartitioning(i#0)
TungstenAggregate(key=[i#0], value=[(sum(cast(j1#1 as bigint)),mode=Partial,isDistinct=false)]
Scan ParquetRelation[file:/user/hive/warehouse/testagg][i#0,j1#1]
```
With this PR, the output will be
```
== Physical Plan ==
TungstenAggregate(key=[i#0], functions=[(sum(cast(j1#1 as bigint)),mode=Final,isDistinct=false)], output=[i#0,sum#18L])
TungstenExchange hashpartitioning(i#0)
TungstenAggregate(key=[i#0], functions=[(sum(cast(j1#1 as bigint)),mode=Partial,isDistinct=false)], output=[i#0,currentSum#22L])
Scan ParquetRelation[file:/user/hive/warehouse/testagg][i#0,j1#1]
```
Author: Yin Huai <yhuai@databricks.com>
Closes #8150 from yhuai/SPARK-9920.
Diffstat (limited to 'sbin/start-slaves.sh')
0 files changed, 0 insertions, 0 deletions