You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/04/28 23:57:04 UTC

[jira] [Created] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select

Elias Levy created FLINK-6419:
---------------------------------

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