File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -82,7 +82,7 @@ object UnionPushDown extends Rule[LogicalPlan] {
8282 * This method relies on the fact that the output attributes of a union are always equal
8383 * to the left child's output.
8484 */
85- private def pushToRight [A <: Expression ](e : A , rewrites : AttributeMap [Attribute ]): A = {
85+ private def pushToRight [A <: Expression ](e : A , rewrites : AttributeMap [Attribute ]) = {
8686 val result = e transform {
8787 case a : Attribute => rewrites(a)
8888 }
@@ -505,7 +505,7 @@ object PushPredicateThroughProject extends Rule[LogicalPlan] {
505505 grandChild))
506506 }
507507
508- private def replaceAlias (condition : Expression , sourceAliases : Map [Attribute , Expression ]): Expression = {
508+ private def replaceAlias (condition : Expression , sourceAliases : Map [Attribute , Expression ]) = {
509509 condition transform {
510510 case a : AttributeReference => sourceAliases.getOrElse(a, a)
511511 }
You can’t perform that action at this time.
0 commit comments