[jira] [Updated] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive
[ 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 SingleOutputStreamOperator apply(R initialValue, > FoldFunctionfoldFunction, WindowFunction 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 SingleOutputStreamOperator apply(ACC initialValue, > FoldFunction foldFunction, WindowFunction function) { > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive
[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3869: Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-3957) > 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: Aljoscha Krettek > > Right now we have this signature: > {code} > public SingleOutputStreamOperator apply(R initialValue, > FoldFunctionfoldFunction, WindowFunction 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 SingleOutputStreamOperator apply(ACC initialValue, > FoldFunction foldFunction, WindowFunction function) { > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive
[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3869: Issue Type: Sub-task (was: Improvement) Parent: FLINK-3957 > WindowedStream.apply with FoldFunction is too restrictive > - > > Key: FLINK-3869 > URL: https://issues.apache.org/jira/browse/FLINK-3869 > Project: Flink > Issue Type: Sub-task > Components: Streaming >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Right now we have this signature: > {code} > public SingleOutputStreamOperator apply(R initialValue, > FoldFunctionfoldFunction, WindowFunction 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 SingleOutputStreamOperator apply(ACC initialValue, > FoldFunction foldFunction, WindowFunction function) { > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)