Add comment.

witgo · Apr 4, 2014 · ec63575 · ec63575
1 parent d0495a9
commit ec63575
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregates.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregates.scala
@@ -188,6 +188,8 @@ case class Aggregate(
 
             var i = 0
             while (i < currentBuffer.length) {
+              // Evaluating an aggregate buffer returns the result.  No row is required since we
+              // already added all rows in the group using update.
               aggregateResults(i) = currentBuffer(i).apply(EmptyRow)
               i += 1
             }