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

龙图腾网获悉杭州电子科技大学申请的专利一种基于Apache Flink的乱序数据流聚合速率限制方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN119473604B 。

龙图腾网通过国家知识产权局官网在2025-11-04发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202411551868.0，技术领域涉及：G06F9/50；该发明授权一种基于Apache Flink的乱序数据流聚合速率限制方法是由徐明;潘思豪;徐建设计研发完成，并于2024-11-01向国家知识产权局提交的专利申请。

本一种基于Apache Flink的乱序数据流聚合速率限制方法在说明书摘要公布了：本发明公开了一种基于ApacheFlink的乱序数据流聚合速率限制方法。本发明提出的流处理系统额外包括了流聚合速率限制器和水深线。本发明应用在聚合存在层级结构一种分层的DAG图的结构上，面向有状态的分布式流聚合问题，以向上传递节点状态的方式优化聚合性能。本发明采用ApacheKafka与生产者和消费者沟通。聚合更新时，根据聚合更新速率是判断上传中间聚合结果还是上传阻塞状态，减少更新无意义的聚合中间结果的维护成本，然后根据阻塞状态来灵活标注水深线形成深水区，深水区限制聚合更新从而降低聚合更新频率，从而降低聚合算法的总体开销。

本发明授权一种基于Apache Flink的乱序数据流聚合速率限制方法在权利要求书中公布了：1.一种基于ApacheFlink的乱序数据流聚合速率限制方法，其特征在于，包括步骤如下： 步骤1：用户根据查询聚合结果的需求设定当前流处理系统中有状态计算的数据结构； 步骤2：在分布式的环境中部署流处理系统和ApacheKafka，流处理系统从Kafka中获得数据流；流处理系统向客户提格式统一的输出端口和输入端口，生产者提供的数据被交给Kafka发送给消费者方的流处理系统；输入端口上的底层节点设置为面向时间的聚合子节点； 步骤3：通过流处理系统从Kafka中读取输入元组，找到输入元组的时间戳所属的节点，并更新该节点；注意，每个元组的处理结束时，从本步骤开始重新执行处理下一个元组； 步骤4：计算对应节点的聚合更新频率，判断聚合更新频率是否超过用户给定的限速，如果当前节点超过限速时，进行向上传递阻塞状态的操作，该操作会更新水位线；否则进入下一步骤；注意，所述的阻塞状态会定期重置，当存在固定的数据访问周期时，则重置周期与用户访问结果节点时间间隔相同，否则由用户决定重置周期长度；此外，阻塞状态存在向上传播的特性即使所有祖先节点一同陷入阻塞的特性，即当一个节点的任意子节点阻塞时，这个节点也会被一同阻塞； 步骤5：当前节点的聚合更新频率未超过限速时，判断输入元组的所属节点是否处于阻塞状态或在深水区内，如果当前节点在深水区中则结束当前元组处理；如果当前节点不在阻塞状态且不在深水区内则向上传递更新，上传遇到处于阻塞状态的节点时提前结束当前元组处理，否则一直上传更新至结果节点然后结束当前元组处理；如果当前节点处于阻塞状态时则进入下一步骤； 步骤6：当前节点处于阻塞状态时，对阻塞来源进行判断，不存在其他阻塞来源时，恢复当前底层节点的状态为通畅，并执行向上传递通畅状态操作；需要注意的是，因为阻塞状态是由下而上决定的，所以传播状态的上传遇到有其他子节点共同导致的阻塞时，上传停止。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人杭州电子科技大学，其通讯地址为：310018 浙江省杭州市钱塘区白杨街道2号大街1158号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。