[ https://issues.apache.org/jira/browse/FLINK-5157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15887803#comment-15887803 ]
ASF GitHub Bot commented on FLINK-5157: --------------------------------------- Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2946#discussion_r103425179 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java --- @@ -478,6 +581,135 @@ public AllWindowedStream(DataStream<T> input, return input.transform(opName, resultType, operator).forceNonParallel(); } + /** + * Applies the given window function to each window. The window function is called for each + * evaluation of the window for each key individually. The output of the window function is + * interpreted as a regular non-windowed stream. + * + * <p>Arriving data is incrementally aggregated using the given aggregate function. This means + * that the window function typically has only a single value to process when called. + * + * @param aggFunction The aggregate function that is used for incremental aggregation. + * @param windowFunction The process window function. + * + * @return The data stream that is the result of applying the window function to the window. + * + * @param <ACC> The type of the AggregateFunction's accumulator + * @param <V> The type of AggregateFunction's result, and the WindowFunction's input + * @param <R> The type of the elements in the resulting stream, equal to the + * WindowFunction's result type + */ + public <ACC, V, R> SingleOutputStreamOperator<R> aggregate( --- End diff -- These should also be `@PublicEvolving`. (I know that the corresponding methods on `WindowedStream` weren't marked like this due to an oversight on the implementers side.) No problem. 😃 > Extending AllWindow Function Metadata > ------------------------------------- > > Key: FLINK-5157 > URL: https://issues.apache.org/jira/browse/FLINK-5157 > Project: Flink > Issue Type: New Feature > Components: DataStream API, Streaming > Reporter: Ventura Del Monte > Assignee: Ventura Del Monte > > Following the logic behind [1,2], ProcessAllWindowFunction can be introduced > in Flink and AllWindowedStream can be extended in order to support them. > [1] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-2+Extending+Window+Function+Metadata > [2] https://issues.apache.org/jira/browse/FLINK-4997 -- This message was sent by Atlassian JIRA (v6.3.15#6346)