[ 
https://issues.apache.org/jira/browse/FLINK-6419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989600#comment-15989600
 ] 

ASF GitHub Bot commented on FLINK-6419:
---------------------------------------

Github user eliaslevy commented on the issue:

    https://github.com/apache/flink/pull/3477
  
    I created [FLINK-6419](https://issues.apache.org/jira/browse/FLINK-6419).


> 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)

Reply via email to