You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/04/26 01:14:00 UTC

[jira] [Created] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition

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)