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 <[email protected]> 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 <[email protected]> Authored: Tue Oct 20 09:20:35 2015 -0700 Committer: Davies Liu <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
