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

龙图腾网获悉广州欢网科技有限责任公司申请的专利一种基于Flink的实时数据处理系统及方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN116932598B 。

龙图腾网通过国家知识产权局官网在2025-10-14发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202311015052.1，技术领域涉及：G06F16/2455；该发明授权一种基于Flink的实时数据处理系统及方法是由常国伟;白俊;杨晓营;马国伟设计研发完成，并于2023-08-11向国家知识产权局提交的专利申请。

本一种基于Flink的实时数据处理系统及方法在说明书摘要公布了：本发明公开了一种基于Flink的实时数据处理系统及方法，属于数据处理领域，数据采集模块通过数据源接入单元连接多种数据源，能够同时接入大量数据；然后基于数据流分区单元对采集到的数据流进行分区，即在处理前就将数据流进行分类，以便同一分区的数据集中处理；数据处理模块中过冷与模式识别单元对每个分区的数据流进行进一步过滤和模式匹配，确定数据流所属事件模式，然后经过时间处理与水印单元以及窗口处理单元对相同同事件模式的数据流采用同以处理方式，即相同事件模式的数据流统一处理，即使数据量较大，也可以对每个数据流确定对应处理方式，利用Flink的流式处理引擎，系统能够以低延迟和高吞吐量处理海量的数据流。

本发明授权一种基于Flink的实时数据处理系统及方法在权利要求书中公布了：1.一种基于Flink的实时数据处理系统，其特征在于，包括：数据采集模块、数据处理模块和结果输出模块； 所述数据采集模块包括： 数据源接入单元，用于通过适配器或连接器与多种数据源连接并从所述多种数据源接入数据流； 数据流分区单元，用于根据数据流中的数据对采集到的数据流进行分区，以确保数据在集群中的均匀分布； 所述数据处理模块包括： 过滤与模式识别单元，用于对数据流分区单元中每个分区的的数据流进行过滤和模式匹配，以确定所述数据流所属的事件模式； 时间处理与水印单元，用于对数据流中生成事件时间并根据所述数据流所示的事件模式确定所述数据流的水位线； 窗口处理单元，用于基于所述事件模式获取所述数据流的特定信息，若所述特定信息满足预设条件，生成所述事件模式对应类型的窗口，所述窗口根据所述水位线对所述数据流进行处理，所述特定信息包括以下至少一项：事件时间、数据流大小和当前收集到的同一事件模式的数量； 所述结果输出模块用于将数据处理模块处理后得到的处理结果输出给目标系统。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人广州欢网科技有限责任公司，其通讯地址为：510000 广东省广州市番禺区小谷围街中二横路22号A513-A514；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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