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)
