@@ -87,16 +87,16 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
8787 val mergeJoin = joins.MergeJoin (leftKeys, rightKeys, planLater(left), planLater(right))
8888 condition.map(Filter (_, mergeJoin)).getOrElse(mergeJoin) :: Nil
8989
90- case ExtractEquiJoinKeys (Inner , leftKeys, rightKeys, condition, left, right) =>
91- val buildSide =
92- if (right.statistics.sizeInBytes <= left.statistics.sizeInBytes) {
93- joins.BuildRight
94- } else {
95- joins.BuildLeft
96- }
97- val hashJoin = joins.ShuffledHashJoin (
98- leftKeys, rightKeys, buildSide, planLater(left), planLater(right))
99- condition.map(Filter (_, hashJoin)).getOrElse(hashJoin) :: Nil
90+ // case ExtractEquiJoinKeys(Inner, leftKeys, rightKeys, condition, left, right) =>
91+ // val buildSide =
92+ // if (right.statistics.sizeInBytes <= left.statistics.sizeInBytes) {
93+ // joins.BuildRight
94+ // } else {
95+ // joins.BuildLeft
96+ // }
97+ // val hashJoin = joins.ShuffledHashJoin(
98+ // leftKeys, rightKeys, buildSide, planLater(left), planLater(right))
99+ // condition.map(Filter(_, hashJoin)).getOrElse(hashJoin) :: Nil
100100
101101 case ExtractEquiJoinKeys (joinType, leftKeys, rightKeys, condition, left, right) =>
102102 joins.HashOuterJoin (
0 commit comments