Spark SQL basicOperator add Intersect operator

Hi all,
I want to submit a basic operator Intersect
For example , in sql case 
select * from table1
intersect
select * from table2
So ,i want use this operator support this function in Spark SQL  
This operator will return the  the intersection of SparkPlan child table RDD .

Author: YanjieGao

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

@@ -204,3 +204,16 @@ case class ExistingRdd(output: Seq[Attribute], rdd: RDD[Row]) extends LeafNode {
   override def execute() = rdd
 }
 
+
+/**
+ * :: DeveloperApi ::
+ */
+@DeveloperApi
+case class Intersect(children: Seq[SparkPlan])(@transient sc: SparkContext) extends SparkPlan {
+  // TODO:
+  override def output = children.head.output
+
+  override def execute() = {
+    children.map(child => child.execute()).foldLeft(children(0).execute())((a, b) => a.intersection(b))
+
+  }