Update basicOperators.scala

YanjieGao · YanjieGao · commit a36eb0a1ec80 · 2014-06-23T15:30:28.000+08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
@@ -89,6 +89,13 @@ case class Join(
   }
 }
 
+case class Except(left: LogicalPlan, right: LogicalPlan) extends BinaryNode {
+  // TODO: These aren't really the same attributes as nullability etc might change.
+  def output = left.output
+
+  def references = Set.empty
+}
+
 case class InsertIntoTable(
     table: LogicalPlan,
     partition: Map[String, Option[String]],

Original file line number	Diff line number	Diff line change
`@@ -89,6 +89,13 @@ case class Join(`
`89`	`89`	`}`
`90`	`90`	`}`
`91`	`91`
	`92`	`+case class Except(left: LogicalPlan, right: LogicalPlan) extends BinaryNode {`
	`93`	`+ // TODO: These aren't really the same attributes as nullability etc might change.`
	`94`	`+ def output = left.output`
	`95`	`+`
	`96`	`+ def references = Set.empty`
	`97`	`+}`
	`98`	`+`
`92`	`99`	`case class InsertIntoTable(`
`93`	`100`	`table: LogicalPlan,`
`94`	`101`	`partition: Map[String, Option[String]],`