flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dawid Wysakowicz (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-10591) Add functions to return TimeIndicators from MATCH_RECOGNIZE
Date Thu, 18 Oct 2018 08:00:05 GMT
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 &amp; 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)

Mime
View raw message