Skip to content

Commit 790765d

Browse files
committed
Update SparkStrategies.scala
1 parent ac73e60 commit 790765d

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
@@ -236,6 +236,8 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
236236
execution.Limit(limit, planLater(child))(sparkContext) :: Nil
237237
case Unions(unionChildren) =>
238238
execution.Union(unionChildren.map(planLater))(sparkContext) :: Nil
239+
case logical.Intersect(left,right) => //yanjiegaonew
240+
execution.Intersect(planLater(left),planLater(right)) :: Nil //yanjiegaonew
239241
case logical.Generate(generator, join, outer, _, child) =>
240242
execution.Generate(generator, join = join, outer = outer, planLater(child)) :: Nil
241243
case logical.NoRelation =>

0 commit comments

Comments
 (0)