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

龙图腾网获悉上海金融期货信息技术有限公司申请的专利基于事件时序信息的分布式异构数据流合流方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115905393B 。

龙图腾网通过国家知识产权局官网在2025-09-26发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202211678253.5，技术领域涉及：G06F16/25；该发明授权基于事件时序信息的分布式异构数据流合流方法是由施周利;潘伟伟设计研发完成，并于2022-12-26向国家知识产权局提交的专利申请。

本基于事件时序信息的分布式异构数据流合流方法在说明书摘要公布了：本发明公开了一种基于事件时序信息的分布式异构数据流合流方法，可实现自主的控制合流过程，将复杂的业务逻辑简单化，解决了合流过程中的复杂逻辑和性能问题，达到高效稳定的合流效果，解决了业务需求。其技术方案为：本发明在Flink中对于存在事件时序的异构数据流的合流做了二级缓存的设计，通过二级缓存简化了复杂的业务逻辑，同时对于原始流水进行了过滤，大大提升了流处理效率，降低了异构流水合流时两个流互相等待造成流处理卡顿的现象。

本发明授权基于事件时序信息的分布式异构数据流合流方法在权利要求书中公布了：1.一种基于事件时序信息的分布式异构数据流合流方法，其特征在于，方法包括主数据流和辅数据流的两个处理流程，其中： 主数据流的处理流程包括： 步骤1-1：接收主数据流数据存入到一级缓存； 步骤1-2：判断所接收到的主数据流数据是否满足一级缓存准出条件，如果满足则进入步骤1-3，如果不满足则主数据流的处理流程结束； 步骤1-3：一级缓存提交到二级缓存； 步骤1-4：根据当前时间清除辅数据二级缓存中过期的数据； 步骤1-5：检查辅数据二级缓存中是否有值；如果有值则进入步骤1-6，否则主数据流的处理流程结束； 步骤1-6：合并主辅二级缓存数据时，以主数据二级缓存中每个时刻的数据为基准，进行合并； 辅数据流的处理流程包括： 步骤2-1：接收辅数据流数据进入一级缓存； 步骤2-2：判断所接收的辅数据流数据是否满足一级缓存，如满足则进入下一步，如果不满足则辅数据流的处理流程结束； 步骤2-3：将一级缓存提交到二级缓存； 步骤2-4：判断主数据流是否结束，如果结束则辅数据流的流程结束，如果未结束则进入步骤2-5； 步骤2-5：合并主辅二级缓存数据时，以主数据二级缓存中每个时刻的数据为基准，进行合并。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人上海金融期货信息技术有限公司，其通讯地址为：200122 上海市浦东新区中国(上海)自由贸易试验区杨高南路288号19-21层；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。