diff options
| author | Davies Liu <davies@databricks.com> | 2015-11-25 21:25:20 -0800 |
|---|---|---|
| committer | Davies Liu <davies.liu@gmail.com> | 2015-11-25 21:25:20 -0800 |
| commit | d1930ec01ab5a9d83f801f8ae8d4f15a38d98b76 (patch) | |
| tree | c5d7d114ea1b9d7e285aa2d96123cb50c65b4dbe /sql | |
| parent | cc243a079b1c039d6e7f0b410d1654d94a090e14 (diff) | |
| download | spark-d1930ec01ab5a9d83f801f8ae8d4f15a38d98b76.tar.gz spark-d1930ec01ab5a9d83f801f8ae8d4f15a38d98b76.tar.bz2 spark-d1930ec01ab5a9d83f801f8ae8d4f15a38d98b76.zip | |
[SPARK-12003] [SQL] remove the prefix for name after expanded star
Right now, the expended start will include the name of expression as prefix for column, that's not better than without expending, we should not have the prefix.
Author: Davies Liu <davies@databricks.com>
Closes #9984 from davies/expand_star.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala index 1b2a8dc4c7..4f89b462a6 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala @@ -204,7 +204,7 @@ case class UnresolvedStar(target: Option[Seq[String]]) extends Star with Unevalu case s: StructType => s.zipWithIndex.map { case (f, i) => val extract = GetStructField(attribute.get, i) - Alias(extract, target.get + "." + f.name)() + Alias(extract, f.name)() } case _ => { |