[jira] [Created] (FLINK-12295) use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen

[Shang Yuanchun (Jira)]

godfrey he created FLINK-12295:
----------------------------------

             Summary: use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen
                 Key: FLINK-12295
                 URL: https://issues.apache.org/jira/browse/FLINK-12295
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / Runtime
            Reporter: godfrey he
            Assignee: godfrey he


after {{FlinkRelMdModifiedMonotonicity}} introduced, an aggregate function whose result value is modified increasing or decreasing could ignore retraction message. We could choose regular aggregate function instead of retract aggregate function for those aggregate functions in code-gen. Currently, this requires the regular aggregate function must implements {{retractExpressions}} method and do not throw any exception. A better approach is the retractable aggregate operator does not call {{retractExpressions}} method for regular aggregate function.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)