Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
adrian-wang committed Apr 14, 2015
1 parent 6e897dd commit c8e82a3
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,8 @@ case class SortMergeJoin(
ClusteredDistribution(leftKeys) :: ClusteredDistribution(rightKeys) :: Nil

// this is to manually construct an ordering that can be used to compare keys from both sides
private val keyOrdering: RowOrdering = RowOrdering.getOrderingFromDataTypes(leftKeys.map(_.dataType))
private val keyOrdering: RowOrdering =
RowOrdering.getOrderingFromDataTypes(leftKeys.map(_.dataType))

private def requiredOrders(keys: Seq[Expression], side: SparkPlan): Ordering[Row] =
newOrdering(keys.map(SortOrder(_, Ascending)), side.output)
Expand Down

0 comments on commit c8e82a3

Please sign in to comment.