From 201a51f36682726d78d9d2fe2c388093bb860ee0 Mon Sep 17 00:00:00 2001
From: Reynold Xin <rxin@databricks.com>
Date: Sat, 21 May 2016 12:46:25 -0700
Subject: [PATCH] [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.
---
.../scala/org/apache/spark/sql/expressions/Aggregator.scala | 3 +++
1 file changed, 3 insertions(+)
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 {
/**
--
GitLab