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

龙图腾网恭喜大连民族大学申请的专利基于事件时间窗口的Gaia平台水位线动态调整方法及装置获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN114443716B 。

龙图腾网通过国家知识产权局官网在2025-03-28发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202210104224.1，技术领域涉及：G06F16/2455；该发明授权基于事件时间窗口的Gaia平台水位线动态调整方法及装置是由黄山;吕鹤轩;艾力卡木·再比布拉;甄妞;贺菲莉;段晓东设计研发完成，并于2022-01-28向国家知识产权局提交的专利申请。

本基于事件时间窗口的Gaia平台水位线动态调整方法及装置在说明书摘要公布了：本申请提供一种基于事件时间窗口的Gaia平台水位线动态调整方法及装置，涉及数据处理领域。该方法包括：获取分布式系统中上一算子传输的流数据，其中，流数据包括数据以及数据产生时的事件时间戳；根据所述流数据，计算算子状态中所述流数据的水位线；根据水位线周期，将所述水位线插入所述流数据以传输至下一算子，该方法通过算子状态中流数据的变化，动态调整水位线，进而保证系统的事件处理的准确性与低延迟。

本发明授权基于事件时间窗口的Gaia平台水位线动态调整方法及装置在权利要求书中公布了：1.一种基于事件时间窗口的Gaia平台水位线动态调整方法，其特征在于，应用于分布式系统的节点，所述方法包括：获取分布式系统中上一算子传输的流数据，其中，流数据包括数据以及数据产生时的事件时间戳；根据所述流数据，计算算子状态中所述流数据的水位线；根据水位线周期，将所述水位线插入所述流数据以传输至下一算子；所述根据所述流数据，计算算子状态中流数据的水位线之前，还包括：为算子分配算子状态，并基于数据流时间模型将当前算子中的所述流数据分为微簇数据；将所述微簇数据的事件时间戳存储在所述算子状态中，其中，所述算子状态存储最新流过当前算子的预设个数据的事件时间戳；所述根据所述流数据，计算算子状态中流数据的水位线，包括：计算获得所述微簇数据的最大事件时间戳；获得所述微簇数据的最大允许乱序时间；计算获得所述微簇数据的乱序度；根据所述最大事件时间戳、所述最大允许乱序时间、所述乱序度以及预设算法，计算获得所述微簇数据的水位线；所述计算获得所述微簇数据的乱序度，包括：当有新的数据流入所述算子时，根据所述微簇数据的事件时间戳计算当前时刻的乱序度；所述根据所述微簇数据的事件时间戳计算当前时刻的乱序度，包括：计算获得所述微簇数据中相邻事件时间戳的差值；计算获得所述微簇数据中相邻事件时间戳差值的绝对值；根据所述微簇数据中相邻事件时间戳的差值以及所述微簇数据中相邻事件时间戳差值的绝对值，计算获得所述微簇数据的乱序度；所述方法还包括：当有新的数据流入所述算子时，根据所述新的数据的事件时间戳更新所述微簇数据的事件时间戳；根据更新的微簇数据计算当前时间的局部乱序度；根据所述当前时间的局部乱序度，调整水位线最大允许乱序时间值；所述预设算法包括：W＝N-M*p；其中，W表示水位线值，N表示当前最大事件时间戳，M表示最大允许乱序时间，p表示乱序度；所述根据所述微簇数据中相邻事件时间戳的差值以及所述微簇数据中相邻事件时间戳差值的绝对值，计算获得所述微簇数据的乱序度，包括：根据公式计算获得所述微簇数据的乱序度；其中，Ti表示所述微簇数据内的第i个事件时间戳，p表示当前微簇数据的乱序度，k表示所述微簇数据内的事件时间戳的总数量。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人大连民族大学，其通讯地址为：116000 辽宁省大连市大连经济技术开发区辽河西路18号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。