CN116881286B-一种数据流连接方法、系统以及存储介质_智臾科技.pdf
免费下载
(19)国家知识产权局
(12)发明专利
(10)授权公告号
(45)授权公告日
(21)申请号 202310907059 .8
(22)申请日 2023 .07 .22
(65)同一申请的已公布的文献号
申请公布号 CN 116881286 A
(43)申请公布日 2023 .10.13
(73)专利权人 浙江智臾科技有限公司
地址 311200 浙江省杭州市萧山区萧山经
济技术开发区启迪路198号B1-303-1
室
(72)发明人 周小华 唐宗勋
(74)专利代理机构 北京维正专利代理有限公司
11508
专利代理师 徐俊
(51)Int.Cl .
G06F
16/2453
(2019 .01)
G06F
16/2455
(2019 .01)
G06F
16/2458
(2019 .01)
(56)对比文件
CN 114116802 A ,2022 .03 .01
CN 111488222 A ,2020 .08 .04
审查员 邵小玲
(54)发明名称
一种数据流连接方法、系统以及存储介质
(57)摘要
本申请涉及数据处理领域，公开了一种数据
流连接方法、系统以及存储介质，其中一种数据
流连接方法包括：接纳多个原始数据流；创建多
个缓存结构，且在每个缓存结构中建立多个数据
队列；将数据分存至对应的缓存结构中；针对每
个缓存结构，基于多个数据队列中的数据的时间
戳信息将主队列中的数据与至少一个从队列中
的数据相连接，以生成并输出目标数据流。本申
请使用缓存结构把数据暂存起来，使得数据处理
更平稳，避免了由于瞬间数据流入过快导致的连
接延迟，同时在缓存结构中为每个原始数据流创
建对应的数据队列，且同一原始数据流的数据可
以在多个缓存结构中独立处理，实现了并行处理
多个数据，提高了整体的数据处理效率。
权利要求书3页 说明书11页 附图2页
CN 116881286 B
2025.07.25
CN 116881286 B
1 .一种数据流连接方法，其特征在于，所述方法包括：
接纳多个原始数据流，所述原始数据流中的数据按照时间序列持续输入；
创建多个缓存结构，且分别在每个所述缓存结构中建立与所述多个原始数据流一一对
应的多个数据队列，所述多个数据队列包括一个主队列和至少一个从队列；
根据每个所述数据的特征信息将所述数据分存至对应的缓存结构中，并且针对每个所
述缓存结构，将来自不同原始数据流的数据分别依序存储至对应的数据队列中；
针对每个所述缓存结构，基于所述多个数据队列中的数据的时间戳信息将所述主队列
中的数据与所述至少一个从队列中的数据相连接，以生成并输出目标数据流；
其中，所述基于所述多个数据队列中的数据的时间戳信息将所述主队列中的数据与所
述至少一个从队列中的数据相连接包括：
根据预设的配置信息确定数据连接模式，并根据所确定的数据连接模式将所述主队列
中的数据与所述至少一个从队列中的数据相连接；
其中，所述数据连接模式包括第一模式和第二模式，在所述第一模式下，所述缓存结构
中的从队列的待连接数据由主队列存在最早的尚未被连接的数据的时间戳t和预设的时间
范围[a ,b]确定，在所述第二模式下，所述缓存结构中的从队列的待连接数据由主队列存在
最早的尚未被连接的数据的时间戳t和前一个存入的数据的时间戳t0确定。
2 .根据权利要求1所述的数据流连接方法，其特征在于，所述基于所述多个数据队列中
的数据的时间戳信息将所述主队列中的数据与所述至少一个从队列中的数据相连接包括：
基于多个从队列中的数据的时间戳信息对部分从队列或者全部从队列中的数据进行
预设的聚合运算以得到聚合数据；
基于所述多个数据队列中的数据的时间戳信息将所述主队列中的数据与所述聚合数
据相连接，或者，基于所述多个数据队列中的数据的时间戳信息将所述主队列中的数据与
所述至少一个从队列中的数据相连接以及所述聚合数据。
3 .根据权利要求1所述的数据流连接方法，其特征在于，所述多个原始数据流仅包括第
一数据流和第二数据流，并且每个所述缓存结构均包括一个主队列和一个从队列，所述主
队列与所述第一数据流相对应，所述从队列与所述第二数据流相对应。
4 .根据权利要求3所述的数据流连接方法，其特征在于，在所确定的数据连接模式是第
一模式的情况下，所述根据所确定的数据连接模式将所述主队列中的数据与所述至少一个
从队列中的数据相连接包括：
获取主队列存在的最早的尚未被连接的数据的时间戳t；
查询从队列最新存入的数据的时间戳t1；
当所述从队列最新存入的数据的时间戳t1大于或等于所述主队列中存在最早的尚未
被连接的数据的时间戳t与所述预设的时间范围[a ,b]左边界a之和的时候触发所述从队列
在[t+a ,t+b]时间范围内的数据与所述主队列t时间戳的数据进行连接，并在所述从队列最
新存入的数据的时间戳t1大于或等于主队列中存在最早的尚未被连接的数据的时间戳t与
所述预设的时间范围[a ,b]右边界b之和的时候输出结果。
5 .权利要求3所述的数据流连接方法，其特征在于，在所确定的数据连接模式是第二模
式的情况下，所述根据所确定的数据连接模式将所述主队列中的数据与所述至少一个从队
列中的数据相连接包括：
权 利 要 求 书
1/3 页
2
CN 116881286 B
2
of 17
免费下载
【版权声明】本文为墨天轮用户原创内容，转载时必须标注文档的来源（墨天轮），文档链接，文档作者等基本信息，否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容，欢迎发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。
下载排行榜
评论