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