You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/01/18 12:29:00 UTC
[jira] [Closed] (FLINK-10591) Add functions to return
TimeIndicators from MATCH_RECOGNIZE
[ https://issues.apache.org/jira/browse/FLINK-10591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Piotr Nowojski closed FLINK-10591.
----------------------------------
Resolution: Fixed
Merged to master as 5 commits starting from ff615ce
> 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
> Assignee: Dawid Wysakowicz
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.8.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> 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)