Skip to content

Commit

Permalink
fix comments
Browse files Browse the repository at this point in the history
  • Loading branch information
yhuai committed Feb 1, 2014
1 parent 235cbb4 commit 45b334b
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/main/scala/catalyst/execution/PlanningStrategies.scala
Original file line number Diff line number Diff line change
Expand Up @@ -143,10 +143,11 @@ trait PlanningStrategies {
object BasicOperators extends Strategy {
def apply(plan: LogicalPlan): Seq[SharkPlan] = plan match {
case logical.Sort(sortExprs, child) =>
// Set the requiredDistribution of this SortPartitions to OrderedDistribution.
// This sort is a global sort. Its requiredDistribution will be an OrderedDistribution.
execution.Sort(sortExprs, true, planLater(child)):: Nil
case logical.SortPartitions(sortExprs, child) =>
// Set the requiredDistribution of this SortPartitions to UnspecifiedDistribution.
// This sort only sort tuples within a partition. Its requiredDistribution will be
// an UnspecifiedDistribution.
execution.Sort(sortExprs, false, planLater(child)) :: Nil
case logical.Project(projectList, child) =>
execution.Project(projectList, planLater(child)) :: Nil
Expand Down

0 comments on commit 45b334b

Please sign in to comment.