File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -79,7 +79,9 @@ abstract class SparkPlan extends QueryPlan[SparkPlan] with Logging with Serializ
7979 def requiredChildOrdering : Seq [Seq [SortOrder ]] = Seq .fill(children.size)(Nil )
8080
8181 /**
82- * Runs this query returning the result as an RDD.
82+ * Returns the result of this query as an RDD[Row] by delegating to doExecute
83+ * after adding query plan information to created RDDs for visualization.
84+ * Concrete implementations of SparkPlan should override doExecute instead.
8385 */
8486 final def execute (): RDD [Row ] = {
8587 RDDOperationScope .withScope(sparkContext, nodeName, false , true ) {
@@ -88,7 +90,8 @@ abstract class SparkPlan extends QueryPlan[SparkPlan] with Logging with Serializ
8890 }
8991
9092 /**
91- * Runs this query returning the result as an RDD.
93+ * Overridden by concrete implementations of SparkPlan.
94+ * Produces the result of the query as an RDD[Row]
9295 */
9396 protected def doExecute (): RDD [Row ]
9497
You can’t perform that action at this time.
0 commit comments