From 214842b0a47edb4d043504ad32263a04fe993f98 Mon Sep 17 00:00:00 2001 From: Wenchen Fan Date: Fri, 12 Jun 2015 14:57:47 +0800 Subject: [PATCH] fix style --- .../org/apache/spark/sql/catalyst/optimizer/Optimizer.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 1b9aad80d4e74..92f79dab7be58 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 @@ -82,7 +82,7 @@ object UnionPushDown extends Rule[LogicalPlan] { * This method relies on the fact that the output attributes of a union are always equal * to the left child's output. */ - private def pushToRight[A <: Expression](e: A, rewrites: AttributeMap[Attribute]): A = { + private def pushToRight[A <: Expression](e: A, rewrites: AttributeMap[Attribute]) = { val result = e transform { case a: Attribute => rewrites(a) } @@ -505,7 +505,7 @@ object PushPredicateThroughProject extends Rule[LogicalPlan] { grandChild)) } - private def replaceAlias(condition: Expression, sourceAliases: Map[Attribute, Expression]): Expression = { + private def replaceAlias(condition: Expression, sourceAliases: Map[Attribute, Expression]) = { condition transform { case a: AttributeReference => sourceAliases.getOrElse(a, a) }