[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837728#comment-15837728
]
ASF GitHub Bot commented on FLINK-5630:
---------------------------------------
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3207#discussion_r97773952
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -18,14 +18,37 @@
package org.apache.flink.api.common.functions;
+import org.apache.flink.annotation.PublicEvolving;
+
import java.io.Serializable;
/**
+ * The {@code AggregateFunction} is a flexible aggregation function,
characterized by the
+ * following features:
+ *
+ * <ul>
+ * <li>The aggregates may use different types for input values,
intermediate aggregates,
+ * and result type, to support a wide range of aggregation
types.</li>
+ *
+ * <li>Support for distributive aggregations: Different intermediate
aggregates can be
+ * merged together, to allow for pre-aggregation/final-aggregation
optimizations.</li>
+ * </ul>
+ *
+ * <p>The {@code AggregateFunction}'s intermediate aggregate (in-progress
aggregation state)
+ * in called the <i>accumulator</i>. Values are added to the accumulator,
and final aggregates are
--- End diff --
Typo: "is called"
> Followups to AggregationFunction
> --------------------------------
>
> Key: FLINK-5630
> URL: https://issues.apache.org/jira/browse/FLINK-5630
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Affects Versions: 1.3.0
> Reporter: Stephan Ewen
> Assignee: Stephan Ewen
> Fix For: 1.3.0
>
>
> Various followup issues to the aggregation function, like
> - Allowing different input/output types for the cases where an additional
> window apply function is specified
> - Adding the {{aggregate()}} methods to the Scala API
> - Adding the window translation tests
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
