Skip to content

Commit 83a3c8a

Browse files
committed
scala style fix
1 parent 14cff80 commit 83a3c8a

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/joinTypes.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,4 +22,4 @@ case object Inner extends JoinType
2222
case object LeftOuter extends JoinType
2323
case object RightOuter extends JoinType
2424
case object FullOuter extends JoinType
25-
case object LeftSemi extends JoinType
25+
case object LeftSemi extends JoinType

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,13 +33,13 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
3333
// Find leftsemi joins where at least some predicates can be evaluated by matching hash keys
3434
// using the HashFilteredJoin pattern.
3535
case HashFilteredJoin(LeftSemi, leftKeys, rightKeys, condition, left, right) =>
36-
val semiJoin =
37-
execution.LeftSemiJoinHash(leftKeys, rightKeys, BuildRight, planLater(left), planLater(right))
36+
val semiJoin = execution.LeftSemiJoinHash(
37+
leftKeys, rightKeys, BuildRight, planLater(left), planLater(right))
3838
condition.map(Filter(_, semiJoin)).getOrElse(semiJoin) :: Nil
3939
// no predicate can be evaluated by matching hash keys
4040
case logical.Join(left, right, LeftSemi, condition) =>
4141
execution.LeftSemiJoinBNL(
42-
planLater(left), planLater(right), LeftSemi, condition)(sparkContext) :: Nil
42+
planLater(left), planLater(right), condition)(sparkContext) :: Nil
4343
case _ => Nil
4444
}
4545
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ case class LeftSemiJoinHash(
235235
*/
236236
@DeveloperApi
237237
case class LeftSemiJoinBNL(
238-
streamed: SparkPlan, broadcast: SparkPlan, joinType: JoinType, condition: Option[Expression])
238+
streamed: SparkPlan, broadcast: SparkPlan, condition: Option[Expression])
239239
(@transient sc: SparkContext)
240240
extends BinaryNode {
241241
// TODO: Override requiredChildDistribution.

0 commit comments

Comments
 (0)