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)