You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2017/10/04 06:11:03 UTC
spark git commit: [SPARK-22193][SQL] Minor typo fix
Repository: spark
Updated Branches:
refs/heads/master 3099c574c -> d54670192
[SPARK-22193][SQL] Minor typo fix
## 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 <re...@gmail.com>
Author: rjoshi2 <re...@gmail.com>
Closes #19422 from rekhajoshm/SPARK-22193.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d5467019
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d5467019
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d5467019
Branch: refs/heads/master
Commit: d54670192a6acd892d13b511dfb62390be6ad39c
Parents: 3099c57
Author: Rekha Joshi <re...@gmail.com>
Authored: Wed Oct 4 07:11:00 2017 +0100
Committer: Sean Owen <so...@cloudera.com>
Committed: Wed Oct 4 07:11:00 2017 +0100
----------------------------------------------------------------------
.../apache/spark/sql/execution/joins/SortMergeJoinExec.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/d5467019/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala
index 14de2dc..4e02803 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala
@@ -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) =>
s"""
|if (comp == 0) {
@@ -463,7 +463,7 @@ case class SortMergeJoinExec(
| continue;
| }
| if (!$matches.isEmpty()) {
- | ${genComparision(ctx, leftKeyVars, matchedKeyVars)}
+ | ${genComparison(ctx, leftKeyVars, matchedKeyVars)}
| if (comp == 0) {
| return true;
| }
@@ -484,7 +484,7 @@ case class SortMergeJoinExec(
| }
| ${rightKeyVars.map(_.code).mkString("\n")}
| }
- | ${genComparision(ctx, leftKeyVars, rightKeyVars)}
+ | ${genComparison(ctx, leftKeyVars, rightKeyVars)}
| if (comp > 0) {
| $rightRow = null;
| } else if (comp < 0) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org