Skip to content

Commit e18d623

Browse files
smolamarmbrus
authored andcommitted
[SPARK-7724] [SQL] Support Intersect/Except in Catalyst DSL.
Author: Santiago M. Mola <santi@mola.io> Closes #6327 from smola/feature/catalyst-dsl-set-ops and squashes the following commits: 11db778 [Santiago M. Mola] [SPARK-7724] [SQL] Support Intersect/Except in Catalyst DSL. (cherry picked from commit e4aef91) Signed-off-by: Michael Armbrust <michael@databricks.com>
1 parent 40989ce commit e18d623

File tree

1 file changed

+4
-0
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl

1 file changed

+4
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl/package.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -276,6 +276,10 @@ package object dsl {
276276

277277
def unionAll(otherPlan: LogicalPlan): LogicalPlan = Union(logicalPlan, otherPlan)
278278

279+
def except(otherPlan: LogicalPlan): LogicalPlan = Except(logicalPlan, otherPlan)
280+
281+
def intersect(otherPlan: LogicalPlan): LogicalPlan = Intersect(logicalPlan, otherPlan)
282+
279283
def sfilter[T1](arg1: Symbol)(udf: (T1) => Boolean): LogicalPlan =
280284
Filter(ScalaUdf(udf, BooleanType, Seq(UnresolvedAttribute(arg1.name))), logicalPlan)
281285

0 commit comments

Comments
 (0)