Skip to content

Commit dd32980

Browse files
committed
update1
1delete sc 2change args to left right 3annotation limit less than 100 charactors
1 parent 4eb43ec commit dd32980

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -206,15 +206,16 @@ case class ExistingRdd(output: Seq[Attribute], rdd: RDD[Row]) extends LeafNode {
206206

207207
/**
208208
* :: DeveloperApi ::
209-
* This operator support the substract function .Return an table with the elements from `this` that are not in `other`.
209+
* This operator support the substract function .
210+
* Return an table with the elements from `this` that are not in `other`.
210211
*/
211212
@DeveloperApi
212-
case class Except(children: Seq[SparkPlan])(@transient sc: SparkContext) extends SparkPlan {
213+
case class Subtract(left:SparkPlan,right:SparkPlan) extends SparkPlan {
213214
// TODO:The input children:Seq[SparkPlan] should only contain two SparkPlan
214215
override def output = children.head.output
215216

216217
override def execute() = {
217-
children(0).execute().subtract(children(1).execute())
218+
left.execute().subtract(right.execute())
218219
}
219220

220221
override def otherCopyArgs = sc :: Nil

0 commit comments

Comments
 (0)