[FLINK-7062] Support the basic functionality of MATCH_RECOGNIZE

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.7.0
• Component/s: Library / CEP, Table SQL / API
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Dian Fu
• Created: 03/Jul/17 03:26
• Updated: 09/Nov/18 11:57
• Resolved: 09/Nov/18 11:57

Description

In this JIRA, we will support the basic functionality of MATCH_RECOGNIZE in Flink SQL API which includes the support of syntax MEASURES, PATTERN and DEFINE. This would allow users write basic cep use cases with SQL like the following example:

SELECT T.aid, T.bid, T.cid
FROM MyTable
MATCH_RECOGNIZE (
  MEASURES
    A.id AS aid,
    B.id AS bid,
    C.id AS cid
  PATTERN (A B C)
  DEFINE
    A AS A.name = 'a',
    B AS B.name = 'b',
    C AS C.name = 'c'
) AS T

Issue Links

• is blocked by: FLINK-9593 Unify AfterMatch semantics with SQL MATCH_RECOGNIZE
• is duplicated by: FLINK-7591 Support partition by and order by of MATCH_RECOGNIZE
• links to: GitHub Pull Request #4502
• links to: GitHub Pull Request #4502
• links to: GitHub Pull Request #6815