Skip to content

Commit eb9d155

Browse files
committed
Fix code style
1 parent 23deb4b commit eb9d155

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -216,15 +216,15 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
216216
val buildSide =
217217
if (left.statistics.sizeInBytes <= right.statistics.sizeInBytes) {
218218
joins.BuildRight
219-
} else {
219+
} else {
220220
joins.BuildLeft
221221
}
222222
execution.joins.CartesianProduct(planLater(left), planLater(right), buildSide) :: Nil
223223
case logical.Join(left, right, Inner, Some(condition)) =>
224224
val buildSide =
225225
if (left.statistics.sizeInBytes <= right.statistics.sizeInBytes) {
226226
joins.BuildRight
227-
} else {
227+
} else {
228228
joins.BuildLeft
229229
}
230230
execution.Filter(condition,

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ case class CartesianProduct(
4141

4242
protected override def doExecute(): RDD[InternalRow] = {
4343
val broadcastedRelation = sparkContext.broadcast(broadcast.execute().map(_.copy()))
44-
broadcastedRelation.value.cartesian(streamed.execute().map(_.copy())).mapPartitions{ iter =>
44+
broadcastedRelation.value.cartesian(streamed.execute().map(_.copy())).mapPartitions { iter =>
4545
val joinedRow = new JoinedRow
4646
buildSide match {
4747
case BuildRight => iter.map(r => joinedRow(r._1, r._2))

0 commit comments

Comments
 (0)