diff options
| author | Reynold Xin <rxin@databricks.com> | 2016-05-21 12:46:25 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-05-21 12:46:25 -0700 |
| commit | 201a51f36682726d78d9d2fe2c388093bb860ee0 (patch) | |
| tree | a95aeda64f39a804e9764e83730b48c8dc7b4f89 | |
| parent | 5e1ee28984b169eaab5d2f832921d32cf09de915 (diff) | |
| download | spark-201a51f36682726d78d9d2fe2c388093bb860ee0.tar.gz spark-201a51f36682726d78d9d2fe2c388093bb860ee0.tar.bz2 spark-201a51f36682726d78d9d2fe2c388093bb860ee0.zip | |
[SPARK-15452][SQL] Mark aggregator API as experimental
## What changes were proposed in this pull request?
The Aggregator API was introduced in 2.0 for Dataset. All typed Dataset APIs should still be marked as experimental in 2.0.
## How was this patch tested?
N/A - annotation only change.
Author: Reynold Xin <rxin@databricks.com>
Closes #13226 from rxin/SPARK-15452.
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/expressions/Aggregator.scala | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/expressions/Aggregator.scala b/sql/core/src/main/scala/org/apache/spark/sql/expressions/Aggregator.scala index baae9dd2d5..51179a528c 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/expressions/Aggregator.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/expressions/Aggregator.scala @@ -17,12 +17,14 @@ package org.apache.spark.sql.expressions +import org.apache.spark.annotation.Experimental import org.apache.spark.sql.{Dataset, Encoder, TypedColumn} import org.apache.spark.sql.catalyst.encoders.encoderFor import org.apache.spark.sql.catalyst.expressions.aggregate.{AggregateExpression, Complete} import org.apache.spark.sql.execution.aggregate.TypedAggregateExpression /** + * :: Experimental :: * A base class for user-defined aggregations, which can be used in [[Dataset]] operations to take * all of the elements of a group and reduce them to a single value. * @@ -48,6 +50,7 @@ import org.apache.spark.sql.execution.aggregate.TypedAggregateExpression * @tparam OUT The type of the final output result. * @since 1.6.0 */ +@Experimental abstract class Aggregator[-IN, BUF, OUT] extends Serializable { /** |