Skip to content

Commit cf232eb

Browse files
committed
update 1comment 2space3 left.out
1 parent f1ea3f3 commit cf232eb

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -207,12 +207,12 @@ case class ExistingRdd(output: Seq[Attribute], rdd: RDD[Row]) extends LeafNode {
207207
/**
208208
* :: DeveloperApi ::
209209
* This operator support the substract function .
210-
* Return an table with the elements from `this` that are not in `other`.
210+
* Return an table with the elements from `left` that are not in `right`.
211211
*/
212212
@DeveloperApi
213-
case class Subtract(left:SparkPlan,right:SparkPlan) extends BinaryNode {
213+
case class Subtract(left: SparkPlan, right: SparkPlan) extends BinaryNode {
214214
// TODO:The input children:Seq[SparkPlan] should only contain two SparkPlan
215-
override def output = children.head.output
215+
override def output = left.output
216216

217217
override def execute() = {
218218
left.execute().map(_.copy()).subtract(right.execute().map(_.copy()))

0 commit comments

Comments
 (0)