You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by da...@apache.org on 2015/10/20 18:20:39 UTC
spark git commit: [SPARK-10463] [SQL] remove PromotePrecision during
optimization
Repository: spark
Updated Branches:
refs/heads/master 60851bc7b -> 94139557c
[SPARK-10463] [SQL] remove PromotePrecision during optimization
PromotePrecision is not necessary after HiveTypeCoercion done.
Jira:
https://issues.apache.org/jira/browse/SPARK-10463
Author: Daoyuan Wang <da...@intel.com>
Closes #8621 from adrian-wang/promoterm.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/94139557
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/94139557
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/94139557
Branch: refs/heads/master
Commit: 94139557c56cea318d4a4f82a4deaf72198f349a
Parents: 60851bc
Author: Daoyuan Wang <da...@intel.com>
Authored: Tue Oct 20 09:20:35 2015 -0700
Committer: Davies Liu <da...@gmail.com>
Committed: Tue Oct 20 09:20:35 2015 -0700
----------------------------------------------------------------------
.../org/apache/spark/sql/catalyst/optimizer/Optimizer.scala | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/94139557/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
index 63602ea..6557c70 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -57,7 +57,7 @@ object DefaultOptimizer extends Optimizer {
ConstantFolding,
LikeSimplification,
BooleanSimplification,
- RemovePositive,
+ RemoveDispensable,
SimplifyFilters,
SimplifyCasts,
SimplifyCaseConversionExpressions) ::
@@ -784,11 +784,12 @@ object SimplifyCasts extends Rule[LogicalPlan] {
}
/**
- * Removes [[UnaryPositive]] identify function
+ * Removes nodes that are not necessary.
*/
-object RemovePositive extends Rule[LogicalPlan] {
+object RemoveDispensable extends Rule[LogicalPlan] {
def apply(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {
case UnaryPositive(child) => child
+ case PromotePrecision(child) => child
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org