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)
