[ https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837732#comment-15837732 ]
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_r97774041 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java --- @@ -81,14 +104,55 @@ * } * } * }</pre> + * + * @param <IN> The type of the values that are aggregated (input values) + * @param <ACC> The type of the accumulator (intermediate aggregate state). + * @param <OUT> The type of the aggregated result */ +@PublicEvolving public interface AggregateFunction<IN, ACC, OUT> extends Function, Serializable { + /** + * Creates a new accumulator, starting a new aggregate. + * + * <p>The new accumulator iy typically meaningless unless a value is added --- End diff -- Typo: "is typically" > 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)