[FLINK-16887] Refactor retraction rules to support inferring ChangelogMode

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 31/Mar/20 15:23
• Updated: 16/May/20 14:26
• Resolved: 15/Apr/20 13:33

Description

Current retraction machanism only support 2 message kinds (+ and -). However, since FLIP-95, we will introduce more message kinds to users (insert/delete/update_before/update_after).

In order to support that, we should first refactor current retraction rules to support ChangelogMode inference. In previous, every node will be attached with a AccMode trait after retraction rule. In the proposed design, we will infer ChangelogMode trait for every node.

Design documentation: https://docs.google.com/document/d/1n_iXIQsKT3uiBqENR8j8RdjRhZfzMhhB66QZvx2rFjE/edit?ts=5e8419c1#

Issue Links

• fixes: FLINK-9528 Incorrect results: Filter does not treat Upsert messages correctly.
• links to: GitHub Pull Request #11674