Skip to content

Commit ac73e60

Browse files
committed
Update basicOperators.scala
1 parent d4ac5e5 commit ac73e60

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

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

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -189,3 +189,10 @@ case class Distinct(child: LogicalPlan) extends UnaryNode {
189189
case object NoRelation extends LeafNode {
190190
override def output = Nil
191191
}
192+
193+
case class Intersect(left: LogicalPlan, right: LogicalPlan) extends BinaryNode {
194+
// TODO: These aren't really the same attributes as nullability etc might change.
195+
def output = left.output
196+
197+
def references = Set.empty
198+
}

0 commit comments

Comments
 (0)