Flink-CEP之模式流與運算符

以前咱們分析了CEP的API，接下來咱們將分析CEP API的內部實現包括模式流與運算符。java 模式流 模式流（PatternStream）是CEP模式匹配的流抽象，一個PatternStream對象表示模式檢測到的序列所對應的流。該序列以映射來表示，以模式名關聯一組事件對象。web 爲了使用PatternStream，咱們首先要構建它，爲此Flink提供了一個名爲CEP的幫助類，它定義了一個

>>阅读原文<<