Polishing comment.

apache · Oct 25, 2016 · 82ebff4 · 82ebff4
1 parent fbf4fd6
commit 82ebff4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala
@@ -299,8 +299,8 @@ case class WholeStageCodegenExec(child: SparkPlan) extends UnaryExecNode with Co
 
   override def outputOrdering: Seq[SortOrder] = child.outputOrdering
   override def executeCollect(): Array[InternalRow] = child match {
-    // This happens when the user is collecting results back to the driver, we could skip
-    // the shuffling and scan increasingly the RDD to get the limited items.
+    // A physical Limit operator has optimized executeCollect which scans increasingly
+    // the RDD to get the limited items, without fully materializing the RDD.
     case g: GlobalLimitExec => g.executeCollect()
     case _ => super.executeCollect()
   }