Skip to content

Commit 61d7f49

Browse files
committed
add omitted comment
1 parent 00a4430 commit 61d7f49

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,7 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
9090
left.statistics.sizeInBytes <= sqlContext.conf.autoBroadcastJoinThreshold =>
9191
makeBroadcastHashJoin(leftKeys, rightKeys, left, right, condition, joins.BuildLeft)
9292

93+
// If the sort merge join option is set, we want to use sort merge join prior to hashjoin
9394
// for now let's support inner join first, then add outer join
9495
case ExtractEquiJoinKeys(Inner, leftKeys, rightKeys, condition, left, right)
9596
if sqlContext.conf.sortMergeJoinEnabled =>

0 commit comments

Comments
 (0)