Minor: Update comment

Andrew Or · Andrew Or · commit ca1b44c01fd0 · 2015-08-07T13:43:35.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregate.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregate.scala
@@ -102,8 +102,8 @@ case class TungstenAggregate(
       }
     }
 
-    // Note: we need to set up the external sorter in each partition before computing
-    // the parent partition, so we cannot simply use `mapPartitions` here (SPARK-9747).
+    // Note: we need to set up the iterator in each partition before computing the
+    // parent partition, so we cannot simply use `mapPartitions` here (SPARK-9747).
     val parentPartition = child.execute().asInstanceOf[RDD[UnsafeRow]]
     val resultRdd = {
       new MapPartitionsWithPreparationRDD[UnsafeRow, UnsafeRow, TungstenAggregationIterator](

Original file line number	Diff line number	Diff line change
`@@ -102,8 +102,8 @@ case class TungstenAggregate(`
`102`	`102`	`}`
`103`	`103`	`}`
`104`	`104`
`105`		`- // Note: we need to set up the external sorter in each partition before computing`
`106`		- // the parent partition, so we cannot simply use `mapPartitions` here (SPARK-9747).
	`105`	`+ // Note: we need to set up the iterator in each partition before computing the`
	`106`	+ // parent partition, so we cannot simply use `mapPartitions` here (SPARK-9747).
`107`	`107`	`val parentPartition = child.execute().asInstanceOf[RDD[UnsafeRow]]`
`108`	`108`	`val resultRdd = {`
`109`	`109`	`new MapPartitionsWithPreparationRDD[UnsafeRow, UnsafeRow, TungstenAggregationIterator](`