Flink的CEP编程之CEP的相关概念

Flink的CEP编程之CEP的相关概念

复杂事件处理（CEP）是一种基于流处理的技术，将系统数据看作不同类型的事件，通 过分析事件之间的关系，建立不同的事件关系序列库，并利用过滤、关联、聚合等技术，最 终由简单事件产生高级事件，并通过模式规则的方式对重要信息进行跟踪和分析，从实时数 据中发掘有价值的信息。复杂事件处理主要应用于防范网络欺诈、设备故障检测、风险规避 和智能营销等领域。Flink 基于 DataStrem API 提供了 FlinkCEP 组件栈，专门用于对复杂 事件的处理，帮助用户从流式数据中发掘有价值的信息。

CEP 相关概念

• 配置依赖
  在使用 FlinkCEP 组件之前，需要将 FlinkCEP 的依赖库引入项目工程中。

 
	org.apache.flink 
	flink-cep-scala_2.11 
	1.9.1 

• 事件定义
  （1）简单事件：简单事件存在于现实场景中，主要的特点为处理单一事件，事件的定义可以 直接观察出来，处理过程中无须关注多个事件之间的关系，能够通过简单的数据处理手 段将结果计算出来。
  （2）复杂事件：相对于简单事件，复杂事件处理的不仅是单一的事件，也处理由多个事件组 成的复合事件。复杂事件处理监测分析事件流(Event Streaming)，当特定事件发生时来触发某些动作。 复杂事件中事件与事件之间包含多种类型关系，常见的有时序关系、聚合关系、层次关 系、依赖关系及因果关系等。