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

龙图腾网获悉郑州大学申请的专利一种流式大数据平台数据实时处理方法及系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN116069296B 。

龙图腾网通过国家知识产权局官网在2026-03-03发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202211379715.3，技术领域涉及：G06F7/78；该发明授权一种流式大数据平台数据实时处理方法及系统是由高景宏;任明星;张文杰;宋晓琴;刘福荣;马倩倩;范兆涵设计研发完成，并于2022-11-04向国家知识产权局提交的专利申请。

本一种流式大数据平台数据实时处理方法及系统在说明书摘要公布了：本发明提供了一种流式大数据平台数据实时处理方法及系统，由用户输入业务的关键时间点以及指定的延时时间，在流式大数据平台启动后，创建一个栈；若当前数据的EventTime比上一个数据的EventTime小，则计算当前数据的EventTime与当前时间的时间差，构建包括数据来源、时间差、是否被丢弃、EventTime的结构体，并将结构体入栈，每隔M个时间窗口计算所述栈中时间差的和，并将栈中数据全部出栈；若接来下的M个时间窗口包括关键时间点，且结构体的个数小于预设值，则将延时时间设置为0；否则，根据时间差的和以及指定的延时时间得到接下来的M个时间窗口范围内的延时时间。本发明不仅满足了大数据处理中的数据完整性要求，而且也能满足对实时性的要求。

本发明授权一种流式大数据平台数据实时处理方法及系统在权利要求书中公布了：1.一种流式大数据平台数据实时处理方法，其特征在于，所述方法包括以下步骤： 步骤1，由用户输入业务的关键时间点以及指定的延时时间，在流式大数据平台启动后，创建一个栈； 步骤3，当一个数据达到所述流式大数据平台时，若当前数据的EventTime比上一个数据的EventTime小，则计算当前数据的EventTime与当前时间的时间差，构建包括数据来源、所述时间差、是否被丢弃、EventTime的结构体，并将所述结构体入栈，每隔M个时间窗口计算所述栈中时间差的和，并将栈中数据全部出栈； 步骤5，若接来下的M个时间窗口包括所述关键时间点，且所述结构体的个数小于预设值，则将延时时间设置为0；否则，根据所述时间差的和以及所述指定的延时时间得到接下来的M个时间窗口范围内的延时时间；其中，延时时间用于与EventTime计算得到WaterMark，M为正整数； 所述根据所述时间差的和以及所述指定的延时时间得到接下来的M个时间窗口范围内的延时时间，具体为：根据所述时间差的和确定延时时间的权重；若接来下的M个时间窗口包括所述关键时间点，且所述结构体的个数不小于预设值，则取所述权重和0.5的最小值作为权重系数，将所述权重系数与所述指定的延时时间的乘积作为新的延时时间；若接来下的M个时间窗口不包括所述关键时间点，则将所述权重作为权重系数，将所述权重系数与所述指定的延时时间的乘积作为新的延时时间。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人郑州大学，其通讯地址为：450000 河南省郑州市高新技术开发区科学大道100号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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