Repository: spark Updated Branches: refs/heads/branch-1.6 399739702 -> d40bf9ad8
[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 <dav...@databricks.com> Closes #9984 from davies/expand_star. (cherry picked from commit d1930ec01ab5a9d83f801f8ae8d4f15a38d98b76) Signed-off-by: Davies Liu <davies....@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d40bf9ad Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d40bf9ad Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d40bf9ad Branch: refs/heads/branch-1.6 Commit: d40bf9ad881f4ba6c550cd61acc2e8c29c9dc60f Parents: 3997397 Author: Davies Liu <dav...@databricks.com> Authored: Wed Nov 25 21:25:20 2015 -0800 Committer: Davies Liu <davies....@gmail.com> Committed: Wed Nov 25 21:25:31 2015 -0800 ---------------------------------------------------------------------- .../scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/d40bf9ad/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala ---------------------------------------------------------------------- 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 1b2a8dc..4f89b46 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 _ => { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
