Skip to content

Commit

Permalink
Updated comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
rxin committed May 5, 2015
1 parent 6be2b4d commit 7233a86
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@ import scala.collection.JavaConversions._
import scala.language.implicitConversions
import scala.reflect.ClassTag
import scala.reflect.runtime.universe.TypeTag
import scala.util.Random
import scala.util.control.NonFatal

import com.fasterxml.jackson.core.JsonFactory
Expand Down Expand Up @@ -457,7 +456,7 @@ class DataFrame private[sql](
return plan
}

// If neither sides have no output set intersection, return the plan.
// If left/right have no output set intersection, return the plan.
val lanalyzed = this.logicalPlan.queryExecution.analyzed
val ranalyzed = right.logicalPlan.queryExecution.analyzed
if (lanalyzed.outputSet.intersect(ranalyzed.outputSet).isEmpty) {
Expand Down

0 comments on commit 7233a86

Please sign in to comment.