Skip to content

Commit 8d4a121

Browse files
committed
add golden files for leftsemijoin
1 parent 83a3c8a commit 8d4a121

File tree

6 files changed

+17
-2
lines changed

6 files changed

+17
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
package org.apache.spark.sql.catalyst.plans.logical
1919

2020
import org.apache.spark.sql.catalyst.expressions._
21-
import org.apache.spark.sql.catalyst.plans.JoinType
21+
import org.apache.spark.sql.catalyst.plans.{LeftSemi, JoinType}
2222
import org.apache.spark.sql.catalyst.types._
2323

2424
case class Project(projectList: Seq[NamedExpression], child: LogicalPlan) extends UnaryNode {
@@ -81,7 +81,12 @@ case class Join(
8181
condition: Option[Expression]) extends BinaryNode {
8282

8383
def references = condition.map(_.references).getOrElse(Set.empty)
84-
def output = left.output ++ right.output
84+
def output = joinType match {
85+
case LeftSemi =>
86+
left.output
87+
case _ =>
88+
left.output ++ right.output
89+
}
8590
}
8691

8792
case class InsertIntoTable(
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
Hank 2
2+
Hank 2
3+
Joe 2
4+
Joe 2

sql/hive/src/test/resources/golden/leftsemijoin-11-80b6466213face7fbcb0de044611e1f5

Whitespace-only changes.

sql/hive/src/test/resources/golden/leftsemijoin-12-d1f6a3dea28a5f0fee08026bf33d9129

Whitespace-only changes.
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
Hank 2
2+
Hank 2
3+
Joe 2
4+
Joe 2
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
2 Tie
2+
2 Tie

0 commit comments

Comments
 (0)