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

Introduce window operator for blink streaming runtime

    XMLWordPrintableJSON

Details

    Description

      We introduced a new window operator in blink streaming runtime, the differences between blink's window operator and the one used in DataStream API are:

      1. The blink's window operator is mainly used by window aggregate. It work closely with SQL's aggregate function, hence we didn't provide the flexibility to apply arbitrary `WindowFunction` like DataStream did. Instead, we only need to save the intermediate accumulate state for aggregate functions. There is no need for us to save original input rows into state, which will be much more efficient.
      2. This new window operator can deal with retract messages.
      3. We did some pane based optimization within sliding window operator, similar with FLINK-7001. 

      Attachments

        Issue Links

          Activity

            People

              ykt836 Kurt Young
              ykt836 Kurt Young
              Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m