[jira] [Created] (FLINK-10591) Add functions to return TimeIndicators from MATCH_RECOGNIZE

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-10591) Add functions to return TimeIndicators from MATCH_RECOGNIZE

Shang Yuanchun (Jira)
Dawid Wysakowicz created FLINK-10591:
----------------------------------------

             Summary: Add functions to return TimeIndicators from MATCH_RECOGNIZE
                 Key: FLINK-10591
                 URL: https://issues.apache.org/jira/browse/FLINK-10591
             Project: Flink
          Issue Type: Sub-task
          Components: CEP, Table API & SQL
    Affects Versions: 1.7.0
            Reporter: Dawid Wysakowicz


In order to be able to apply windowing on top of results from MATCH_RECOGNIZE clause we have to provide a way to return proper TimeIndicator. We cannot simply return rowtime/proctime for any row of the match, cause match can be finalized e.g. by the first non matching row (in case of greedy), so the TimeIndicator will be equal to the timestamp of that non-matching row.

The suggestion is to provide functions:
* MATCH_ROWTIME()
* MATCH_PROCTIME()
that will output rowtime/proctime indicators.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)