Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6047 Add support for Retraction in Table API / SQL
  3. FLINK-6091

Implement and turn on the retraction for aggregates

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Implemented
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Table SQL / API
    • Labels:
      None

      Description

      Implement functions for generating and consuming retract messages for different aggregates.
      1. add delete/add property to Row
      2. implement functions for generating retract messages for unbounded groupBy
      3. implement functions for handling retract messages for different aggregates.
      4. handle retraction messages in CommonCorrelate and CommonCalc (retain Delete property).

      Note: Currently, only unbounded groupby generates retraction and it is working under unbounded and processing time mode. Hence, retraction is only supported for unbounded and processing time aggregations so far. We can add more retraction support later.

      supported now: unbounded groupby, unbounded and processing time over window
      unsupported now: group window, event time or bounded over window.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                hequn8128 Hequn Cheng
                Reporter:
                ShaoxuanWang Shaoxuan Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: