[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek updated FLINK-3869: ------------------------------------ Assignee: Yassine Marzougui (was: Aljoscha Krettek) > WindowedStream.apply with FoldFunction is too restrictive > --------------------------------------------------------- > > Key: FLINK-3869 > URL: https://issues.apache.org/jira/browse/FLINK-3869 > Project: Flink > Issue Type: Improvement > Components: Streaming > Reporter: Aljoscha Krettek > Assignee: Yassine Marzougui > > Right now we have this signature: > {code} > public <R> SingleOutputStreamOperator<R> apply(R initialValue, > FoldFunction<T, R> foldFunction, WindowFunction<R, R, K, W> function) { > {code} > but we should have this signature to allow users to return a type other than > the fold accumulator type from their window function: > {code} > public <ACC, R> SingleOutputStreamOperator<R> apply(ACC initialValue, > FoldFunction<T, ACC> foldFunction, WindowFunction<ACC, R, K, W> function) { > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)