Skip to content

Commit 61d1a7e

Browse files
committed
Fix code sytle
1 parent 0a62098 commit 61d1a7e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,8 @@ case class CartesianProduct(left: SparkPlan, right: SparkPlan) extends BinaryNod
3434
val leftResults = left.execute().map(_.copy())
3535
val rightResults = right.execute().map(_.copy())
3636

37-
val cartesianRdd = if(leftResults.partitions.size > rightResults.partitions.size) {
38-
rightResults.cartesian(leftResults).mapPartitions{ iter =>
37+
val cartesianRdd = if (leftResults.partitions.size > rightResults.partitions.size) {
38+
rightResults.cartesian(leftResults).mapPartitions { iter =>
3939
iter.map(tuple => (tuple._2, tuple._1))
4040
}
4141
} else {

0 commit comments

Comments
 (0)