flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive
Date Mon, 21 Nov 2016 15:29:58 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683857#comment-15683857

Aljoscha Krettek commented on FLINK-3869:

[~ymarzougui] Did it work out in the end for the Scala API? In the PR I see that you also
add the methods for the Scala API (I haven't checked out the code yet)

[~sjwiesman] Is the PR more or less what you also have in your version?

> 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

View raw message