scala style fix

manishamde · May 21, 2014 · 83a3c8a · 83a3c8a
1 parent 14cff80
commit 83a3c8a
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/joinTypes.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/joinTypes.scala
@@ -22,4 +22,4 @@ case object Inner extends JoinType
 case object LeftOuter extends JoinType
 case object RightOuter extends JoinType
 case object FullOuter extends JoinType
-case object LeftSemi extends JoinType
+case object LeftSemi extends JoinType
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala
@@ -33,13 +33,13 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
       // Find leftsemi joins where at least some predicates can be evaluated by matching hash keys
       // using the HashFilteredJoin pattern.
       case HashFilteredJoin(LeftSemi, leftKeys, rightKeys, condition, left, right) =>
-        val semiJoin =
-          execution.LeftSemiJoinHash(leftKeys, rightKeys, BuildRight, planLater(left), planLater(right))
+        val semiJoin = execution.LeftSemiJoinHash(
+          leftKeys, rightKeys, BuildRight, planLater(left), planLater(right))
         condition.map(Filter(_, semiJoin)).getOrElse(semiJoin) :: Nil
       // no predicate can be evaluated by matching hash keys
       case logical.Join(left, right, LeftSemi, condition) =>
         execution.LeftSemiJoinBNL(
-          planLater(left), planLater(right), LeftSemi, condition)(sparkContext) :: Nil
+          planLater(left), planLater(right), condition)(sparkContext) :: Nil
       case _ => Nil
     }
   }

diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins.scala
@@ -235,7 +235,7 @@ case class LeftSemiJoinHash(
  */
 @DeveloperApi
 case class LeftSemiJoinBNL(
-    streamed: SparkPlan, broadcast: SparkPlan, joinType: JoinType, condition: Option[Expression])
+    streamed: SparkPlan, broadcast: SparkPlan, condition: Option[Expression])
     (@transient sc: SparkContext)
   extends BinaryNode {
   // TODO: Override requiredChildDistribution.