Flink的CEP编程之CEP的相关概念
原创
wx62be9d88ce294博主文章分类:大数据 ©著作权
文章标签 flink big data scala 事件处理 数据 文章分类 Hadoop 大数据
©著作权归作者所有:来自51CTO博客作者wx62be9d88ce294的原创作品,请联系作者获取转载授权,否则将追究法律责任
复杂事件处理(CEP)是一种基于流处理的技术,将系统数据看作不同类型的事件,通 过分析事件之间的关系,建立不同的事件关系序列库,并利用过滤、关联、聚合等技术,最 终由简单事件产生高级事件,并通过模式规则的方式对重要信息进行跟踪和分析,从实时数 据中发掘有价值的信息。复杂事件处理主要应用于防范网络欺诈、设备故障检测、风险规避 和智能营销等领域。Flink 基于 DataStrem API 提供了 FlinkCEP 组件栈,专门用于对复杂 事件的处理,帮助用户从流式数据中发掘有价值的信息。
CEP 相关概念
- 配置依赖
在使用 FlinkCEP 组件之前,需要将 FlinkCEP 的依赖库引入项目工程中。
<dependency>
<groupId>org.apache.flinkgroupId>
<artifactId>flink-cep-scala_2.11artifactId>
<version>1.9.1version>
dependency>
-
事件定义
(1)简单事件:简单事件存在于现实场景中,主要的特点为处理单一事件,事件的定义可以 直接观察出来,处理过程中无须关注多个事件之间的关系,能够通过简单的数据处理手 段将结果计算出来。
(2)复杂事件:相对于简单事件,复杂事件处理的不仅是单一的事件,也处理由多个事件组 成的复合事件。复杂事件处理监测分析事件流(Event Streaming),当特定事件发生时来触发某些动作。 复杂事件中事件与事件之间包含多种类型关系,常见的有时序关系、聚合关系、层次关 系、依赖关系及因果关系等。 -
赞
- 收藏
- 评论
- *举报
Original: https://blog.51cto.com/u_15704423/5434863
Author: wx62be9d88ce294
Title: Flink的CEP编程之CEP的相关概念
原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/516934/
转载文章受原作者版权保护。转载请注明原作者出处!