CEP模式匹配

PARTITION BY

否

将数据行进行逻辑上的分组。

ORDER BY

否

在分区中对数据行进行逻辑排序。

[ONE ROW | ALL ROWS] PER MATCH

否

为每个匹配选择输出汇总或者明细。

• ONE ROW PER MATCH：每次检测到完整的匹配后进行汇总输出。
• ALL ROWS PER MATCH：检测到完整的匹配后会把匹配过程中每条具体记录进行输出。

示例如下：

		SELECT * FROM MyTable MATCH_RECOGNIZE
		(
		  MEASURES AVG(B.id) as Bid
		  ALL ROWS PER MATCH
		  PATTERN (A B C)
		  DEFINE
			A AS A.name = 'a',
			B AS B.name = 'b',
			C as C.name = 'c'
		) MR

示例说明：

假设MyTable数据格式为(id,name), 有三条数据(1,a) (2,b), (3,c)。

那么ONE ROW PER MATCH会输出B的平均值2。

ALL ROWS PER MATCH会将每条记录及B的平均值输出，也就是输出(1,a, null), (2,b,2), (3,c,2)。

MEASURES

否

定义要输出的度量值。

PATTERN

是

定义要匹配的模式。

• 连续事件 PATTERN (A B C)即表示检测连续的ABC事件。
• 逻辑事件PATTERN (A | B)即表示检测A或者B。

• 修饰符
  • * ：0次或多次迭代，如A* 匹配0次或多次A
  • + ：1次或多次迭代，如A+ 匹配1次或多次A
  • ? ：0次或1次迭代，如A？ 匹配0次或多次A
  • {n} ： n 次迭代 (n > 0)，如A{5} 匹配5次A
  • {n,} ： n 次或更多次迭代 (n >= 0)，如A{5,} 匹配>=5次A
  • {n,m} ： n次至m次 (包括n和m) 迭代 (0 <= n <= m, 0 < m)，如A{3,6} 匹配3至6次A
  • {,m} ： 0次至m次 (包括0和m) 迭代 (m > 0)，如A{,4} 匹配0至4次A

DEFINE

是

定义主要的模式变量条件。

AFTER MATCH SKIP

否

定义在一个匹配找到之后从哪里开始下一轮匹配。

• SKIP TO NEXT ROW ：在当前匹配第一行之后的下一行开始下一轮模式匹配
• SKIP PAST LAST ROW ：在当前匹配的最后一行之后的下一行开始下一轮匹配
• SKIP TO FIRST variable：从当前匹配的第一个variable开始下一轮匹配
• SKIP TO LAST variable：从当前匹配的最后一个variable开始下一轮匹配
• SKIP TO variable：同SKIP TO LAST variable

MATCH_NUMBER()

说明本次匹配属于第几次匹配。可用在MEASURES和DEFINE子句中。

CLASSIFIER()

说明当前记录被匹配到PATTERN里的哪个模式变量里。可用在MEASURES和DEFINE子句中。

FIRST()/LAST()

每次匹配里的第一个/最后一个记录。比如PATTERN (A B+ C), FIRST(B.id)代表匹配里的第一个B的id，LAST(B.id)代表匹配里的最后一个B的id。

NEXT()/PREV()

相对偏移，可用在DEFINE里。比如PATTERN (A B+) DEFINE B AS B.price > PREV(B.price)。

RUNNING/FINAL

RUNNING 表示匹配过程中间值，FINAL表示最终结果值，RUNNING/FINAL一般只在ALL ROWS PER MATCH里才有意义。比如有三条记录(a, 2), (b, 6), (c, 12), 那么RUNNING AVG(A.price)和FINAL AVG(A.price)的值就是(2, 6), (4, 6), (6, 6)。

聚合函数(COUNT, SUM, AVG, MAX, MIN)

聚合操作，可用在MEASURES和DEFINE子句中。关于聚合函数的详细信息，请参见聚合函数。