Skip to content

Commit 26f833f

Browse files
committed
update SparkStrategies.scala on master branch
[SPARK-2234][SQL]Spark SQL basicOperators add Except operator #1151
1 parent 8dd063f commit 26f833f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,8 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
182182
execution.Limit(limit, planLater(child))(sparkContext) :: Nil
183183
case Unions(unionChildren) =>
184184
execution.Union(unionChildren.map(planLater))(sparkContext) :: Nil
185+
case logical.Except(left,right) =>
186+
execution.Subtract(planLater(left),planLater(right)) :: Nil
185187
case logical.Generate(generator, join, outer, _, child) =>
186188
execution.Generate(generator, join = join, outer = outer, planLater(child)) :: Nil
187189
case logical.NoRelation =>

0 commit comments

Comments
 (0)