Repository: spark
Updated Branches:
  refs/heads/master cc243a079 -> d1930ec01


[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.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d1930ec0
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d1930ec0
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d1930ec0

Branch: refs/heads/master
Commit: d1930ec01ab5a9d83f801f8ae8d4f15a38d98b76
Parents: cc243a0
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:20 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/d1930ec0/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

Reply via email to