细说Flink CEP_152.pdf
需积分: 9 109 浏览量
2020-03-24
16:08:24
上传
评论
收藏 942KB PDF 举报
细说Flink CEP
本文由浅入深（从相关背景、!"# 使用，到具体实现）介绍 $%&'( 当前的 )*" 模块。
读者需要对 $%&'(+,-.-/.01-2+!"# 有一定了解，内容比较全面，请据所需选读。+
背景介绍
什么是CEP？
全称 Complex(event(processing，专指解决3从一系列具体源事件实时地推导（或
提取、感知）出所需的更复杂更抽象的事件4的一类技术。+
别看 )*" 解决的问题就一句话，其实应用场景极其广泛：量化交易（如通过实时
的股票交易数据判断一些价格转折点及时作出买卖操作）、监控系统（根据监测
数据实时检测复杂的异常）、物联网传感器数据分析（此类应用场景很多，工业
制造、医疗、智慧城市等均需要 )*"）等。总之，在有非常多源数据（事件）以
流的形式产生时，需要对其分析、实时感知并作出响应的场景，都属于 )*" 的应
用场景。+
)*" 有一些重要特征：+
• 实时性：)*"是需要实时感知并作出响应的，至于实时具体是多长时间，
这个根据场景可能是毫秒级，也可能是秒级，分钟级的在一些监控场景
也可能。一般从充足的源事件输入到输出结果事件的延迟是毫秒级。+
• 复合性：+
输入事件可以有一个或多个事件源，一般是从多个（甚至很多）序列事
件进行推导。+
• 与数据库相反的处理逻辑：数据库是先存储数据，再查询需要的结果，
即先有数据，再运行查询；而)*"是先定义好查询，再用实时数据去匹配
查询，即先有查询，再运行数据。+
目前 )*" 的技术产品非常多，比如 *5610、/&778&、!9:01+/.01-2+!'-%;.&<5。+
剩余15页未读，继续阅读
资源评论
