ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[SPARK-22193][SQL] Minor typo fix

Browse source 
## What changes were proposed in this pull request?

[SPARK-22193][SQL] Minor typo fix in SortMergeJoinExec. Nothing major, but it bothered me going into.Hence fixing

## How was this patch tested?
existing tests

Author: Rekha Joshi <rekhajoshm@gmail.com>
Author: rjoshi2 <rekhajoshm@gmail.com>

Closes #19422 from rekhajoshm/SPARK-22193.
This commit is contained in:
Rekha Joshi 2017-10-04 07:11:00 +01:00 committed by Sean Owen
parent 3099c574c5
commit d54670192a
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala
View file

@ -402,7 +402,7 @@ case class SortMergeJoinExec(
} }
} }
private def genComparision(ctx: CodegenContext, a: Seq[ExprCode], b: Seq[ExprCode]): String = { private def genComparison(ctx: CodegenContext, a: Seq[ExprCode], b: Seq[ExprCode]): String = {
val comparisons = a.zip(b).zipWithIndex.map { case ((l, r), i) => val comparisons = a.zip(b).zipWithIndex.map { case ((l, r), i) =>
s""" s"""
|if (comp == 0) { |if (comp == 0) {
@ -463,7 +463,7 @@ case class SortMergeJoinExec(
| continue; | continue;
| } | }
| if (!$matches.isEmpty()) { | if (!$matches.isEmpty()) {
| ${genComparision(ctx, leftKeyVars, matchedKeyVars)} | ${genComparison(ctx, leftKeyVars, matchedKeyVars)}
| if (comp == 0) { | if (comp == 0) {
| return true; | return true;
| } | }
@ -484,7 +484,7 @@ case class SortMergeJoinExec(
| } | }
| ${rightKeyVars.map(_.code).mkString("\n")} | ${rightKeyVars.map(_.code).mkString("\n")}
| } | }
| ${genComparision(ctx, leftKeyVars, rightKeyVars)} | ${genComparison(ctx, leftKeyVars, rightKeyVars)}
| if (comp > 0) { | if (comp > 0) {
| $rightRow = null; | $rightRow = null;
| } else if (comp < 0) { | } else if (comp < 0) {