flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Elias Levy (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select
Date Mon, 01 May 2017 03:42:04 GMT

     [ https://issues.apache.org/jira/browse/FLINK-6419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Elias Levy closed FLINK-6419.
    Resolution: Duplicate

> 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