Aljoscha Krettek created FLINK-3869: ---------------------------------------
Summary: 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 <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)