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)
