95-872-050-源码-CEP-CEP之模式流与运算符

Posted 2021-10-25 九师兄

文章目录

• 1.视界
• 2.概述
• 3.模式流
• 4.运算符

1.视界

2.概述

CEP API的内部实现包括模式流与运算符。

3.模式流

​ 模式流（PatternStream）是CEP模式匹配的流抽象，一个PatternStream对象表示模式检测到的序列所对应的流。该序列以映射来表示，以模式名关联一组事件对象。

​ 为了使用PatternStream，我们首先要构建它，为此Flink提供了一个名为CEP的帮助类，它定义了一个pattern静态方法：

DataStream<String<