aitozi created FLINK-9883:
-----------------------------

             Summary: 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


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
(v7.6.3#76005)

Reply via email to