买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉中兴飞流信息科技有限公司申请的专利在分布式流数据处理引擎实现复杂事件处理的方法及系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN114385686B 。

龙图腾网通过国家知识产权局官网在2025-06-27发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202210046713.6，技术领域涉及：G06F16/2455；该发明授权在分布式流数据处理引擎实现复杂事件处理的方法及系统是由陈翔设计研发完成，并于2022-01-19向国家知识产权局提交的专利申请。

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

本发明授权在分布式流数据处理引擎实现复杂事件处理的方法及系统在权利要求书中公布了：1.一种在分布式流数据处理引擎实现复杂事件处理的系统，其特征在于，所述系统包括分布式流数据处理引擎，所述分布式流数据处理引擎中嵌入有CEP模块和CEP算子；所述CEP模块包括有：事件模式定义子模块、NFA子模块、事件模式处理子模块； 所述事件模式定义子模块，用于定义需要匹配的事件序列模式，以及定义匹配成功的事件序列的处理逻辑； 所述事件模式处理子模块， 所述NFA子模块，用于接收事件序列，并根据事件本身信息以及当前状态信息更新状态和匹配信息； 所述CEP算子，用于处理不同时间语义下的事件序列，并将语义正确的事件序列发送给独立的NFA子模块去处理；其中，所述CEP算子处理不同时间语义下的事件序列的过程包括：根据指定的时间语义对事件进行判断，确定所述事件为实际处理时间还是事件发生时间；如果是实际处理时间，则继续判断是否需要在相同时间戳的事件中按预设顺序进行处理；并在不需要处理时，更新时间信息，以及将所述事件直接交给NFA子模块进行处理，并记录更新后的NFA子模块状态；否则，在需要处理时，缓存该事件，直到实际处理时间增加后，统一处理对应时间戳下所有缓存的事件；如果是事件发生时间，则继续判断事件中包含的实际发生时间是否超过当前程序处理的最小事件时间；如果没有超过，则缓存该事件，直到实际处理时间增加后，统一处理对应时间戳下所有缓存的事件；如果超过，则判定所述事件为迟到事件，并进行对应处理。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中兴飞流信息科技有限公司，其通讯地址为：210012 江苏省南京市雨花台区软件大道50号6号楼；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。