CEStream:一种复杂事件流处理语言

摘要：

复杂事件处理是支持大数据处理的流式计算平台的核心技术之一.CEStream语言作为一种新型的事件流处理语言,支持分布式环境下的复杂事件处理.该语言以XML等层次化数据为数据模型,为复杂事件检测提供了一种正规树模式匹配功能,并且支持结构连接和正规式匹配.同时,针对分布式的多个事件流,其能够将各个事件源模式匹配的结果按照时间顺序再一次进行正规式模式匹配,满足多源组合型复杂事件的检测需求,具有较强的事件处理能力.为了实现CEStream语言,研制了一个基于流数据处理集群和远端查询代理的执行引擎系统.该系统通过远程查询代理实现基于正规树模式的事件检测,通过流处理集群完成多源组合型复杂事件处理.实验表明,该系统实现了CEStream语言,有效地限制了各个节点之间的通信量,充分利用了集群的计算能力,整体性能能够满足应用需求.

关键词：复杂事件处理、计算机语言、流式计算

所属期刊栏目：44

分类号：TP311(计算技术、计算机技术)

资助基金：北京市自然科学基金项目4122011;国家自然科学基金青年基金项目61202074

在线出版日期：2017-05-16（万方平台首次上网日期，不代表论文的发表时间）

页数：共5页

页码：140-143,164