flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "aitozi (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-9883) Filter the target window to calculate when deal with slidewindow
Date Thu, 19 Jul 2018 09:52:00 GMT

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

aitozi commented on FLINK-9883:

I think it over again, maybe it can be done by user custom trigger. Do you think is it necessary
to add a default implementation class to make this convenient [~aljoscha], If it is not
necessary from your side, i will close this issue.

> Filter the target window to calculate when deal with slidewindow
> ----------------------------------------------------------------
>                 Key: FLINK-9883
>                 URL: https://issues.apache.org/jira/browse/FLINK-9883
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>    Affects Versions: 1.5.1
>            Reporter: aitozi
>            Assignee: aitozi
>            Priority: Major
> When the SlideWindow deal with the ContinuousProcessingTimeTrigger or ContinuousEventTimeTrigger
will trigger all the related slide window to process, but when user only care about the data
like the recent 30 days, the slidewindow's maxTimestamp which exceed today is not need to
be process, so i think we should add support to filter the slidewindow rather than ask user
to filter in the windowProcessFunction.  What's your idea [~aljoscha]

This message was sent by Atlassian JIRA

View raw message