Skip to content

Commit

Permalink
Update comment
Browse files Browse the repository at this point in the history
  • Loading branch information
Andrew Or committed May 8, 2015
1 parent 0d49fd6 commit 1e211db
Showing 1 changed file with 5 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,9 @@ abstract class SparkPlan extends QueryPlan[SparkPlan] with Logging with Serializ
def requiredChildOrdering: Seq[Seq[SortOrder]] = Seq.fill(children.size)(Nil)

/**
* Runs this query returning the result as an RDD.
* Returns the result of this query as an RDD[Row] by delegating to doExecute
* after adding query plan information to created RDDs for visualization.
* Concrete implementations of SparkPlan should override doExecute instead.
*/
final def execute(): RDD[Row] = {
RDDOperationScope.withScope(sparkContext, nodeName, false, true) {
Expand All @@ -88,7 +90,8 @@ abstract class SparkPlan extends QueryPlan[SparkPlan] with Logging with Serializ
}

/**
* Runs this query returning the result as an RDD.
* Overridden by concrete implementations of SparkPlan.
* Produces the result of the query as an RDD[Row]
*/
protected def doExecute(): RDD[Row]

Expand Down

0 comments on commit 1e211db

Please sign in to comment.