Skip to content

Commit 0c0082b

Browse files
committed
Fix line length.
1 parent cbc664c commit 0c0082b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,8 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
3535
def apply(plan: LogicalPlan): Seq[SparkPlan] = plan match {
3636
// Find left semi joins where at least some predicates can be evaluated by matching join keys
3737
case ExtractEquiJoinKeys(LeftSemi, leftKeys, rightKeys, condition, left, right) =>
38-
val semiJoin = joins.LeftSemiJoinHash(leftKeys, rightKeys, planLater(left), planLater(right))
38+
val semiJoin = joins.LeftSemiJoinHash(
39+
leftKeys, rightKeys, planLater(left), planLater(right))
3940
condition.map(Filter(_, semiJoin)).getOrElse(semiJoin) :: Nil
4041
// no predicate can be evaluated by matching hash keys
4142
case logical.Join(left, right, LeftSemi, condition) =>

0 commit comments

Comments
 (0)