0

我们知道,在 Flink CEP Java 中,可以使用 next()、followBy() 和 Continuous() 等 API 来设置不同模式之间的连续性。但是,在 CEP SQL 中,由于语法比较简单,很难清楚地描述模式之间的连续性。

我的问题是,如果定义的模式是 PATTERN(a b+ c),是否所有匹配模式 a、b 和 c 的事件都严格连续?我的意思是,CEP SQL 中的 PATTERN(a b+ c) 是否等同于 CEP Java 中的 a.next(b).oneOrMore().consecutive().next(c)?

例如,对于PATTERN(a b+ c),如果输入事件流是{abbbc axbxbc},我只想输出{abbbc},因为{axbxbc}包含不匹配的事件x,需要排除。

4

0 回答 0