ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix Aggregator documentation (rename present to finish).

Browse source
This commit is contained in:
Reynold Xin 2015-11-25 13:45:41 -08:00
parent 4e81783e92
commit ecac283545
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
sql/core/src/main/scala/org/apache/spark/sql/expressions/Aggregator.scala
View file

@ -34,7 +34,7 @@ import org.apache.spark.sql.{DataFrame, Dataset, Encoder, TypedColumn}
* def zero: Int = 0 * def zero: Int = 0
* def reduce(b: Int, a: Data): Int = b + a.i * def reduce(b: Int, a: Data): Int = b + a.i
* def merge(b1: Int, b2: Int): Int = b1 + b2 * def merge(b1: Int, b2: Int): Int = b1 + b2
* def present(r: Int): Int = r * def finish(r: Int): Int = r
* }.toColumn() * }.toColumn()
* *
* val ds: Dataset[Data] = ... * val ds: Dataset[Data] = ...