Skip to content

Commit

Permalink
SPARK-3462 remove now-unused parameter
Browse files Browse the repository at this point in the history
  • Loading branch information
Cody Koeninger committed Sep 11, 2014
1 parent 0788691 commit 5c8d24d
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,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.
*/
def pushToRight[A <: Expression](e: A, union: Union, rewrites: AttributeMap[Attribute]): A = {
def pushToRight[A <: Expression](e: A, rewrites: AttributeMap[Attribute]): A = {
val result = e transform {
case a: Attribute => rewrites(a)
}
Expand All @@ -82,14 +82,14 @@ object UnionPushdown extends Rule[LogicalPlan] {
val rewrites = buildRewrites(u)
Union(
Filter(condition, left),
Filter(pushToRight(condition, u, rewrites), right))
Filter(pushToRight(condition, rewrites), right))

// Push down projection into union
case Project(projectList, u @ Union(left, right)) =>
val rewrites = buildRewrites(u)
Union(
Project(projectList, left),
Project(projectList.map(pushToRight(_, u, rewrites)), right))
Project(projectList.map(pushToRight(_, rewrites)), right))
}
}

Expand Down

0 comments on commit 5c8d24d

Please sign in to comment.