We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6e897dd commit c8e82a3Copy full SHA for c8e82a3
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala
@@ -47,7 +47,8 @@ case class SortMergeJoin(
47
ClusteredDistribution(leftKeys) :: ClusteredDistribution(rightKeys) :: Nil
48
49
// this is to manually construct an ordering that can be used to compare keys from both sides
50
- private val keyOrdering: RowOrdering = RowOrdering.getOrderingFromDataTypes(leftKeys.map(_.dataType))
+ private val keyOrdering: RowOrdering =
51
+ RowOrdering.getOrderingFromDataTypes(leftKeys.map(_.dataType))
52
53
private def requiredOrders(keys: Seq[Expression], side: SparkPlan): Ordering[Row] =
54
newOrdering(keys.map(SortOrder(_, Ascending)), side.output)
0 commit comments