[FLINK-27401] CEP supports AggregateFunction in IterativeCondition

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.16.0
• Fix Version/s: 1.20.0
• Component/s: Library / CEP
• Labels: pull-request-available stale-assigned
• Assignee: Yue Ma
• Reporter: Nicholas Jiang
• Created: 26/Apr/22 01:13
• Updated: 11/Mar/24 12:44

Description

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.

Issue Links

• links to: GitHub Pull Request #19674