本发明提供一种在分布式流数据处理引擎实现复杂事件处理的方法及系统，首先获取预先定义的需要匹配的事件序列模式以及数据处理逻辑，再将CEP算子嵌入至所述数据处理逻辑中，并对分布式流数据处理引擎下发执行指令；获取进入CEP算子中的事件，并按照取键逻辑将所述时间分配至分区中某个键对应的事件队列中；最后判断所述事件中的时间概念是实际处理时间还是事件发生时间，并根据判断结果进行对应的事件处理。本发明提供一种有效的用于在现有的分布式流数据处理引擎上实现CEP的方案，该方案在实现了一个功能完善的CEP模块的同时，还将其与现有的分布式流数据处理引擎加以融合，使其完美继承处理引擎的诸多优良特性，能够在大规模的数据量下水平拓展。