[ https://issues.apache.org/jira/browse/FLINK-6419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Elias Levy closed FLINK-6419. ----------------------------- Resolution: Duplicate > Better support for CEP quantified conditions in PatternSelect.select > -------------------------------------------------------------------- > > Key: FLINK-6419 > URL: https://issues.apache.org/jira/browse/FLINK-6419 > Project: Flink > Issue Type: Improvement > Components: CEP > Affects Versions: 1.3.0 > Reporter: Elias Levy > Priority: Minor > > Flink 1.3 introduces to the API quantifer methods which allow one to > declaratively specific how many times a condition must be matched before > there is a state change. > The pre-existing {{PatternSelect.select}} method does not account for this > change very well. The selection function passed to {{select}} receives a > {{Map[String,T]}} as an argument that permits the function to look up the > matched events by the condition's name. > To support the new functionality that permits a condition to match multiple > elements, when a quantifier is greater than one, the matched events are > stored in the map by appending the condition's name with an underscore and an > index value. > While functional, this is less than ideal. It would be best if conditions > with quantifier that is a multiple returned the matched events in an array > and if they were accessible via the condition's name, without have to > construct keys from the condition's name and an index, and iterate querying > the map until no more are found. -- This message was sent by Atlassian JIRA (v6.3.15#6346)