You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2016/02/01 20:22:16 UTC
spark git commit: [SPARK-12989][SQL] Delaying Alias Cleanup after
ExtractWindowExpressions
Repository: spark
Updated Branches:
refs/heads/master 6075573a9 -> 33c8a490f
[SPARK-12989][SQL] Delaying Alias Cleanup after ExtractWindowExpressions
JIRA: https://issues.apache.org/jira/browse/SPARK-12989
In the rule `ExtractWindowExpressions`, we simply replace alias by the corresponding attribute. However, this will cause an issue exposed by the following case:
```scala
val data = Seq(("a", "b", "c", 3), ("c", "b", "a", 3)).toDF("A", "B", "C", "num")
.withColumn("Data", struct("A", "B", "C"))
.drop("A")
.drop("B")
.drop("C")
val winSpec = Window.partitionBy("Data.A", "Data.B").orderBy($"num".desc)
data.select($"*", max("num").over(winSpec) as "max").explain(true)
```
In this case, both `Data.A` and `Data.B` are `alias` in `WindowSpecDefinition`. If we replace these alias expression by their alias names, we are unable to know what they are since they will not be put in `missingExpr` too.
Author: gatorsmile <ga...@gmail.com>
Author: xiaoli <li...@gmail.com>
Author: Xiao Li <xi...@Xiaos-MacBook-Pro.local>
Closes #10963 from gatorsmile/seletStarAfterColDrop.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/33c8a490
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/33c8a490
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/33c8a490
Branch: refs/heads/master
Commit: 33c8a490f7f64320c53530a57bd8d34916e3607c
Parents: 6075573
Author: gatorsmile <ga...@gmail.com>
Authored: Mon Feb 1 11:22:02 2016 -0800
Committer: Michael Armbrust <mi...@databricks.com>
Committed: Mon Feb 1 11:22:02 2016 -0800
----------------------------------------------------------------------
.../org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 5 +++--
.../scala/org/apache/spark/sql/DataFrameWindowSuite.scala | 10 ++++++++++
2 files changed, 13 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/33c8a490/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
index 5fe700e..ee60fca 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
@@ -883,12 +883,13 @@ class Analyzer(
if (missingExpr.nonEmpty) {
extractedExprBuffer += ne
}
- ne.toAttribute
+ // alias will be cleaned in the rule CleanupAliases
+ ne
case e: Expression if e.foldable =>
e // No need to create an attribute reference if it will be evaluated as a Literal.
case e: Expression =>
// For other expressions, we extract it and replace it with an AttributeReference (with
- // an interal column name, e.g. "_w0").
+ // an internal column name, e.g. "_w0").
val withName = Alias(e, s"_w${extractedExprBuffer.length}")()
extractedExprBuffer += withName
withName.toAttribute
http://git-wip-us.apache.org/repos/asf/spark/blob/33c8a490/sql/core/src/test/scala/org/apache/spark/sql/DataFrameWindowSuite.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameWindowSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameWindowSuite.scala
index d38842c..2bcbb19 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameWindowSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameWindowSuite.scala
@@ -344,4 +344,14 @@ class DataFrameWindowSuite extends QueryTest with SharedSQLContext {
Row("b", 1, null, null, null, null, null, null),
Row("b", 2, null, null, null, null, null, null)))
}
+
+ test("SPARK-12989 ExtractWindowExpressions treats alias as regular attribute") {
+ val src = Seq((0, 3, 5)).toDF("a", "b", "c")
+ .withColumn("Data", struct("a", "b"))
+ .drop("a")
+ .drop("b")
+ val winSpec = Window.partitionBy("Data.a", "Data.b").orderBy($"c".desc)
+ val df = src.select($"*", max("c").over(winSpec) as "max")
+ checkAnswer(df, Row(5, Row(0, 3), 5))
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org