break line

adrian-wang · adrian-wang · commit ee1b64f8c132 · 2015-06-08T02:08:00.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashOuterJoin.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashOuterJoin.scala
@@ -48,7 +48,8 @@ case class HashOuterJoin(
     case LeftOuter => left.outputPartitioning
     case RightOuter => right.outputPartitioning
     case FullOuter => UnknownPartitioning(left.outputPartitioning.numPartitions)
-    case x => throw new IllegalArgumentException(s"HashOuterJoin should not take $x as the JoinType")
+    case x =>
+      throw new IllegalArgumentException(s"HashOuterJoin should not take $x as the JoinType")
   }
 
   override def requiredChildDistribution: Seq[ClusteredDistribution] =

Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,8 @@ case class HashOuterJoin(`
`48`	`48`	`case LeftOuter => left.outputPartitioning`
`49`	`49`	`case RightOuter => right.outputPartitioning`
`50`	`50`	`case FullOuter => UnknownPartitioning(left.outputPartitioning.numPartitions)`
`51`		`- case x => throw new IllegalArgumentException(s"HashOuterJoin should not take $x as the JoinType")`
	`51`	`+ case x =>`
	`52`	`+ throw new IllegalArgumentException(s"HashOuterJoin should not take $x as the JoinType")`
`52`	`53`	`}`
`53`	`54`
`54`	`55`	`override def requiredChildDistribution: Seq[ClusteredDistribution] =`