MapReduce服务 MRS-Flink CEP in SQL增强:SQL查询语法

时间：2025-02-12 15:03:44

MapReduce服务 MRS

SQL查询语法

通过MATCH_RECOGNIZE的SQL语法实现。MATCH_RECOGNIZE子句自Oracle Database 12c起由Oracle SQL支持，用于在SQL中表示事件模式匹配。Apache Calcite同样支持MATCH_RECOGNIZE子句。

由于Flink通过Calcite分析SQL查询结果，本操作遵循Apache Calcite语法。

MATCH_RECOGNIZE (      [ PARTITION BY expression [, expression ]* ]      [ ORDER BY orderItem [, orderItem ]* ]      [ MEASURES measureColumn [, measureColumn ]* ]      [ ONE ROW PER MATCH | ALL ROWS PER MATCH ]      [ AFTER MATCH            ( SKIP TO NEXT ROW            | SKIP PAST LAST ROW            | SKIP TO FIRST variable            | SKIP TO LAST variable            | SKIP TO variable )      ]      PATTERN ( pattern )      [ WITHIN intervalLiteral ]      [ SUBSET subsetItem [, subsetItem ]* ]      DEFINE variable AS condition [, variable AS condition ]*      )

MATCH_RECOGNIZE子句的语法元素定义如下：

-PARTITION BY [可选]：定义分区列。该子句为可选子句。如果未定义，则使用并行度1。

-ORDER BY [可选]：定义数据流中事件的顺序。ORDER BY子句为可选子句，如果忽略则使用非确定性排序。由于事件顺序在模式匹配中很重要，因此大多数情况下应指定该子句。

-MEASURES [可选]：指定匹配成功的事件的属性值。

-ONE ROW PER MATCH | ALL ROWS PER MATCH [可选]：定义如何输出结果。ONE ROW PER MATCH表示每次匹配只输出一行，ALL ROWS PER MATCH表示每次匹配的每一个事件输出一行。

-AFTER MATCH [可选]：指定从何处开始对下一个模式匹配进行匹配成功后的处理。

-PATTERN：将匹配模式定义为正则表达式格式。PATTERN子句中可使用以下运算符：连接运算符，量词运算符(*，+，?，{n}，{n,}, {n,m}, {,m}),分支运算符（使用竖线‘|’），以及异运算符（‘{- -}’）。

-WITHIN [可选]：当且仅当匹配发生在指定时间内，则输出模式子句匹配。

-SUBSET [可选]：将DEFINE子句中定义的一个或多个关联变量组合在一起。

-DEFINE：指定boolean条件，该条件定义了PATTERN子句中使用的变量。

此外，还支持以下函数：

-MATCH_NUMBER()：可用于MEASURES子句中，为同一成功匹配的每一行分配相同编号。