[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15671614#comment-15671614 ]
Seth Wiesman edited comment on FLINK-3869 at 11/16/16 9:05 PM: --------------------------------------------------------------- [~aljoscha] [~ymarzougui] This is an issue I have been following as it affects a project I am working on. I have a fix that works with both the Java and Scala api's that I would be happy to contribute. Edit: To clarify, this is using the reduce, fold api proposed by Aljoscha above. was (Author: sjwiesman): [~aljoscha] [~ymarzougui] This is an issue I have been following as it affects a project I am working on. I have a fix that works with both the Java and Scala api's that I would be happy to contribute. > 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)