FlinkCEP 中提供了 Pattern API 用于对输入流数据的复杂事件规则定义，并从事件流 中抽取事件结果。包含四个步骤：
一.模式定义
定义 Pattern 可以是单次执行模式，也可以是循环执行模式。单词执行模式一次只接受 一个事件，循环执行模式可以接收一个或者多个事件。通常情况下，可以通过指定循环次数 将单次执行模式变为循环执行模式。每种模式能够将多个条件组合应用到同一事件之上，条 件组合可以通过 where 方法进行叠加。每个 Pattern 都是通过 begin 方法定义的
下一步通过 Pattern.where()方法在 Pattern 上指定 Condition，只有当 Condition 满 足之后，当前的 Pattern 才会接受事件。
每个模式都需要指定触发条件，作为事件进入到该模式是否接受的判断依据，当事件中 的数值满足了条件时，便进行下一步操作。在 FlinkCFP 中通过 pattern.where()、 pattern.or()及 pattern.until()方法来为 Pattern 指定条件，且 Pattern 条件有 Simple Conditions 及 Combining Conditions 等类型。
将相互独立的模式进行组合然后形成模式序列。模式序列基本的编写方式和独立模式一致，各个模式之间通过邻近条件进行连接即可，其中有严格邻近、宽松邻近、非确定宽松邻 近三种邻近连接条件。
注意：
1、所有模式序列必须以 .begin() 开始
2、模式序列不能以 .notFollowedBy() 结束
3、”not” 类型的模式不能被 optional 所修饰
4、此外，还可以为模式指定时间约束，用来要求在多长时间内匹配有效
二.模式检测
调用 CEP.pattern()，给定输入流和模式，就能得到一个 PatternStream
三.选择结果
得到 PatternStream 类型的数据集后，接下来数据获取都基于 PatternStream 进行。该 数据集中包含了所有的匹配事件。目前在 FlinkCEP 中提供 select 和 flatSelect 两种方法 从 PatternStream 提取事件结果事件。
Original: https://blog.51cto.com/u_15704423/5434864
Author: wx62be9d88ce294
Title: Flink的CEP编程之Pattern API
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/516932/
转载文章受原作者版权保护。转载请注明原作者出处！