Flink复杂事件处理 (CEP)教程

1、CEP语法SELECT [ ALL | DISTINCT ]{ * | variable [,variable]* }FROM tableExpressionMATCH_RECOGNIZE ([PARTITION BY { variable [,variable]*}]ORDER BY {orderItem [, orderItem]*}MEASURES {measureItem AS col [,variable AS col]*}ONE ROW PER MATCH[AFTER MATCH SKIP]PATTERN (patternVariable[quantifier] [ patternVariable[quantifier]]*)[WITHIN intervalExpression]DEFINE {patternVariable AS patternDefinationExpression [, patternVar iable AS patternDefinationExpression]*} )];

2、SQL语义