flink 复杂事件

这篇博客文章试图总结CEP领域中的技术,并介绍它们的主要功能和不足。 有时似乎过度使用了CEP一词(就像'ESB'一样),下面的内容反映了我们对它的理解和理解。

ESPER( http://esper.codehaus.org/ )是流行的开源组件,可用于Java的复杂事件处理(CEP)。 它包括对基于滑动时间或长度窗口的模式匹配和流处理的丰富支持。 尽管对“ CEP”一词进行了激烈的讨论( http://www.dbms2.com/2011/08/25/renaming-cep-or-not /),但ESPER似乎非常适合CEP术语,因为借助ESPER的EPL(事件处理语言),它似乎能够从一系列简单事件中真正识别出“复杂事件”。

最近,在寻找用于实时CEP的开源解决方案时,我们的小组偶然发现了Twitter的Storm项目( https://github.com/nathanmarz/storm )。 它声称与Yahoo的S4最具有可比性,并且与Esper和Streambase等“复杂事件处理”系统处于同一空间。 我不确定Streambase,但是更深入地研究Storm项目使它看起来与CEP和ESPER解决方案大不相同。 与S4同上( http://incubator.apache.org/s4/ )。 尽管S4和Storm似乎擅长于分布式模式下的实时流处理,并且它们看上去(如他们声称的那样)是“实时Hadoop”,但它们似乎没有提供匹配模式的规定(因此表示复杂事件)。
搜索(我们的研究可能与之相关的)CEP定义导致以下项目符号( http://colinclark.sys-con.com/node/1985400 ),其中包括以下四个作为系统/解决方案的先决条件被称为CEP组件/项目/解决方案:

  • 领域特定语言
  • 连续查询
  • 时间或长度窗口
  • 时间模式匹配
在当前版本的S4和Storm项目中,似乎缺少完全支持时间/长度窗口和时间模式匹配的连续查询。 可能是由于它们的婴儿期,他们将来会逐渐成熟以包含这些功能。 到目前为止,它们似乎只适合预处理事件流,然后再将其传递给ESPER等CEP引擎。 他们的分布式处理能力(la map-reduce模式)可以帮助加快预处理速度,在此情况下,可以过滤事件,或者通过一些查找/计算等来丰富事件。还进行了一些尝试,将Storm与Esper集成( http://tomdzk.wordpress.com/2011/09/28/storm-esper/ )。

虽然像S4和Storm这样的处理系统缺少CEP的重要功能,但基于ESPER的系统具有受内存限制的缺点。 事件太多或时间窗口过长可能会导致ESPER内存不足。 如果使用ESPER处理实时流(例如来自社交媒体的实时流),则ESPER内存中将积累大量数据。 总体而言,问题陈述是为大数据发明CEP解决方案。 在更好的层面上,问题陈述包括设计CEP解决方案,以处理机载(批处理)和飞行中(实时)数据。

用DarkStar的术语( http://www.eventprocessing-communityofpractice.org/EPS-presentations/Clark_EP.pdf ),要求是“实时匹配注册的模式,在数据库中发现类似的模式”。 由于受内存限制是一个限制,因此,如果可以找到某种凝聚内存事件的机制,可能会很有用。 但是,压缩后的数据仍然应该有意义,并保留原始流的上下文。

DarkStar使用符号聚合近似值( http://www.cs.ucr.edu/~eamonn/SAX.htm )进行此操作,他们声称通过将SAX与AsterData的nCluster一起使用来满足上述要求,nCluster是mpp(大规模并行)使用基于SQL / MapReduce( http://www.asterdata.com/resources/mapreduce.php )的嵌入式分析引擎处理数据库)。

待续(随着我们的进一步研究)…

参考:来自我们的JCG合作伙伴 Abhishek Jain 的复杂(事件)世界   在NS.Infra博客上。

翻译自: https://www.javacodegeeks.com/2012/03/complex-event-world.html

flink 复杂事件

flink 复杂事件_复杂的(事件)世界相关推荐

  1. mysql数据库什么是事件_[数据库]Mysql 事件(定时任务)

    [数据库]Mysql 事件(定时任务) 0 2016-04-25 18:00:28 mysql 创建任务(事件) 1.检查数据库事件是否开启,如果 event_scheduler 等于 NO表示开启 ...

  2. java响应鼠标滚轮事件_鼠标滚轮事件MouseWheel

    其实在大多数浏览器(IE6, IE7, IE8, Opera 10+, Safari 5+,Chrome)中,都提供了 "mousewheel" 事件.但杯具的是 Firefox ...

  3. java 异步事件_处理异步事件的三种方式

    在网站开发中,异步事件是项目必然需要处理的一个环节,也因为前端框架的兴起,通过框架实现的 SPA 已经是快速建构网站的标配了,一部获取数据也就成了不可或缺的一环:本文来就讲一讲 JavaScript ...

  4. python文本框事件_文本框事件

    1.文本框焦点问题 onBlur:当失去输入焦点后产生该事件 onFocus:当输入获得焦点后,产生该文件 Onchange:当文字值改变时,产生该事件 OnseleCT:当文字加亮后,产生该文件 o ...

  5. html文本框鼠标离开事件,html鼠标事件_文本框事件

    该楼层疑似违规已被系统折叠 隐藏此楼查看此楼 今天57号网络技术分享给大家介绍html鼠标事件,就是当前文本框获得焦点时,里面的原有文本清零. 首先我们来看一看源代码运行后的效果图片: 你也可以[点击 ...

  6. 计算器java鼠标按钮事件_[java]ItemEvent事件:简单计算器

    代码: Example9_8.java public class Example9_8 { public static void main(String args[]){ WindowOperatio ...

  7. 同一个按钮绑定多个事件_带你走进JavaScript世界系列——事件处理程序之 IE 事件处理...

    IE 事件处理程序 IE 实现了与 DOM 中类似的两个方法:attachEvent() 和 detachEvent() .这两个方法接收相同的两个参数:事件处理程序名称和事件处理程序函数.通过 at ...

  8. js 监听 安卓事件_百行代码实现js事件监听实现跨页面数据传输

    百行代码实现js事件监听实现跨页面数据传输 使用场景 类似消息队列的使用场景,支持同页面和跨页面通信,发送消息和接收消息 技术原理 跨页面通信: 基于事件监听,通过监听 storage事件监听回调机制 ...

  9. jqgrid 单元格绑定点击事件_自定义事件带参数的触发过程

    (接上讲) 这一讲我们先继续上一讲类模块代码的讲解: 6 Private Sub mySht_Change(ByVal Target As Range) RaiseEvent mySelectRanA ...

  10. 触发事件_黑暗的三天之触发事件

    作者:Elizabeth Marie 翻译:地狱天堂你决定 我非常犹豫来释放这些信息,因为现在,在网络上,有如此多关于黑暗的三天的信息.但是,我也一直在领受关于这个事件的信息,因此,我会忠实,并分享它 ...

最新文章

  1. php 去除实体,php – 如何在学说中正确关闭实体管理器
  2. java 成员变量 成员方法_《Java基础知识》Java成员变量,成员方法,构造方法和析构方法...
  3. mysql 语音_MySQL 在各种程序语音的连接字符串(转)
  4. Kali Linux常用服务配置教程DHCP服务原理
  5. 【Shell】使用记录
  6. Egret note
  7. .net连接MYSQL数据库方法一
  8. 利用MFC向导生成单文档应用程序框架
  9. Google 的垄断正在扼杀自由软件!
  10. 破解wifi密码最简单教程 就三步
  11. /usr/bin/ld: /tmp/ccIHWHTn.o: in function `Cdisk::Cdisk()‘:编译报错解决方案
  12. BOSS创投社群:要想成为富人,得改变原有思维,谈谈什么是富人思维模式!
  13. ITeye4月读书活动之《游戏引擎架构》
  14. Rouge | 自动文摘及机器翻译评价指标
  15. pam_shells.so
  16. Windows 编程中的数据类型(转自:维基百科)
  17. 判断顺序栈栈满的两种方式
  18. 【EMC电磁兼容】01.10——了解一下天线
  19. 循序渐进:用python做金融量化分析(四)双均线系统策略
  20. AXI 基础第 5 讲-创建 AXI4-Lite Sniffer IP 以在赛灵思Vivado IP Integrator中使用

热门文章

  1. Tomcat 服务自动启动
  2. 【最全最详细】使用publiccms实现动态可维护的导航菜单栏
  3. 《四世同堂》金句摘抄(十五)
  4. 用startSmoothScroll实现RecyclerView滚动到指定位置并置顶,含有动画。
  5. springmvc sends and receives data by ajax request using json format
  6. 微信小程序定时器setInterval()的使用注意事项
  7. 纹理和基元_自定义基元和DTO的(反)序列化和验证
  8. payara 创建 集群_Apache Payara:让我们加密
  9. ebook_[EBOOK]十大Java性能问题
  10. jhipster_JHipster入门,第3部分