File tree Expand file tree Collapse file tree 2 files changed +1
-3
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 2 files changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -188,7 +188,6 @@ private[sql] case class EnsureRequirements(sqlContext: SQLContext) extends Rule[
188
188
case (required, child) => required.nonEmpty && required != child
189
189
}
190
190
191
-
192
191
// True iff outputPartitionings of children are compatible with each other.
193
192
// It is possible that every child satisfies its required data distribution
194
193
// but two children have incompatible outputPartitionings. For example,
Original file line number Diff line number Diff line change @@ -47,8 +47,7 @@ case class SortMergeJoin(
47
47
ClusteredDistribution (leftKeys) :: ClusteredDistribution (rightKeys) :: Nil
48
48
49
49
// this is to manually construct an ordering that can be used to compare keys from both sides
50
- private val keyOrdering : RowOrdering =
51
- RowOrdering .forSchema(leftKeys.map(_.dataType))
50
+ private val keyOrdering : RowOrdering = RowOrdering .forSchema(leftKeys.map(_.dataType))
52
51
53
52
override def outputOrdering : Seq [SortOrder ] = requiredOrders(leftKeys)
54
53
You can’t perform that action at this time.
0 commit comments