Nicholas Jiang created FLINK-27401:
--------------------------------------
Summary: CEP supports AggregateFunction in IterativeCondition
Key: FLINK-27401
URL: https://issues.apache.org/jira/browse/FLINK-27401
Project: Flink
Issue Type: Improvement
Components: Library / CEP
Affects Versions: 1.16.0
Reporter: Nicholas Jiang
Fix For: 1.16.0
IterativeCondition only exposes the filter interface. For the aggregation
operation in the condition, since the condition may be called multiple times in
the NFA process, an event may cause the custom aggregation state in the
condition to be updated multiple times, for example, filters goods with a total
of more than 1000 orders in the past 10 minutes. AggregateFunction is
introduced in IterativeCondition to initialize and maintain aggregation state.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
