flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Elias Levy (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select
Date Fri, 28 Apr 2017 23:57:04 GMT
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

View raw message