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

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),当特定事件发生时来触发某些动作。 复杂事件中事件与事件之间包含多种类型关系,常见的有时序关系、聚合关系、层次关 系、依赖关系及因果关系等。

  • 收藏
  • 评论
  • *举报

上一篇:Flink的Time详解之Watermark原理

下一篇:Flink的CEP编程之Pattern API

Original: https://blog.51cto.com/u_15704423/5434863
Author: wx62be9d88ce294
Title: Flink的CEP编程之CEP的相关概念

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/516934/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球