Skip to content

Commit

Permalink
comment out unmatched code
Browse files Browse the repository at this point in the history
  • Loading branch information
Ishiihara committed Nov 9, 2014
1 parent 5cb98c3 commit cc4647d
Showing 1 changed file with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -87,16 +87,16 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
val mergeJoin = joins.MergeJoin(leftKeys, rightKeys, planLater(left), planLater(right))
condition.map(Filter(_, mergeJoin)).getOrElse(mergeJoin) :: Nil

case ExtractEquiJoinKeys(Inner, leftKeys, rightKeys, condition, left, right) =>
val buildSide =
if (right.statistics.sizeInBytes <= left.statistics.sizeInBytes) {
joins.BuildRight
} else {
joins.BuildLeft
}
val hashJoin = joins.ShuffledHashJoin(
leftKeys, rightKeys, buildSide, planLater(left), planLater(right))
condition.map(Filter(_, hashJoin)).getOrElse(hashJoin) :: Nil
// case ExtractEquiJoinKeys(Inner, leftKeys, rightKeys, condition, left, right) =>
// val buildSide =
// if (right.statistics.sizeInBytes <= left.statistics.sizeInBytes) {
// joins.BuildRight
// } else {
// joins.BuildLeft
// }
// val hashJoin = joins.ShuffledHashJoin(
// leftKeys, rightKeys, buildSide, planLater(left), planLater(right))
// condition.map(Filter(_, hashJoin)).getOrElse(hashJoin) :: Nil

case ExtractEquiJoinKeys(joinType, leftKeys, rightKeys, condition, left, right) =>
joins.HashOuterJoin(
Expand Down

0 comments on commit cc4647d

Please sign in to comment.