在复杂事件处理(CEP)中,处理乱序、延迟和重复事件对实时分析至关重要,尤其是在处理来自多个来源的异构数据的资源受限设备上。我们提出了LimeCEP,这是一种混合CEP方法,结合了懒惰评估、缓冲和推测处理,以高效地处理数据不一致,并支持在放宽语义下的多模式检测。LimeCEP集成了Kafka,实现高效的消息排序、保留和重复消除,并提供可配置的策略,以在准确性、延迟和资源消耗之间进行权衡。与SASE和FlinkCEP等最先进的系统相比,LimeCEP的延迟低至六个数量级,同时内存使用减少了十倍,CPU利用率降低了六倍,在高乱序输入流下保持近乎完美的精确度和召回率,使其非常适合非云部署。
Kyrama等(星期三)研究了这个问题。