Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-9883

Filter the target window to calculate when deal with slidewindow

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Won't Fix
    • 1.5.1
    • None
    • API / DataStream
    • None

    Description

      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

      Attachments

        Activity

          People

            aitozi WenJun Min
            aitozi WenJun Min
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: