数据分发方法、介质及电子设备

    公开(公告)号:CN110086847B

    公开(公告)日:2021-03-09

    申请号:CN201910183275.6

    申请日:2019-03-12

    Abstract: 本发明提供一种数据分发方法、介质和电子设备,所述方法包括:拥有待分发数据的节点运行推送程序,所述推送程序用于在整个分发过程结束前重复地执行推送处理,所述推送处理包括:根据节点间的传输速率将所述数据推送至一待推送节点,其中所述拥有待分发数据的节点到所述待推送节点的传输速率在所述拥有待分发数据的节点到所有待推送节点的传输速率中为最高且不为0;所述待推送节点在接收到所述数据后,作为拥有待分发数据的节点运行所述推送程序。本发明减少了数据在网络中分发的时延,有效提高了网络带宽的利用率。

    基于分级复用的日志数据流的查询共享方法和系统

    公开(公告)号:CN107193898B

    公开(公告)日:2019-12-03

    申请号:CN201710320562.8

    申请日:2017-05-09

    Inventor: 张进东 孙毓忠

    Abstract: 本发明涉及一种基于分级复用的日志数据流的查询共享方法和系统,包括:将包含多个查询语句的查询操作注册到系统,通过设定滑动窗口对日志数据流中的元组进行截取;对多个该查询语句进行预处理,提取其中具有相同子查询的查询语句,并将其所查询结果作为中间结果加以存储,该中间结果用以在多个查询操作间进行共享;从所截取元组中提取具有相同中间存储结构的元组,并将其采用共享队列的方式加以存储以在多个查询操作间进行共享。本发明针对日志流查询存储共享,保证对日志流元组的数据进行有效存储、快速索引的前提下,也为数据共享情况下的迁移提供了灵活性;针对子查询共享,通过对相同谓词查询的抽取和共享,达到计算资源共享的目的。

    数据分发方法、介质及电子设备

    公开(公告)号:CN110086847A

    公开(公告)日:2019-08-02

    申请号:CN201910183275.6

    申请日:2019-03-12

    Abstract: 本发明提供一种数据分发方法、介质和电子设备,所述方法包括:拥有待分发数据的节点运行推送程序,所述推送程序用于在整个分发过程结束前重复地执行推送处理,所述推送处理包括:根据节点间的传输速率将所述数据推送至一待推送节点,其中所述拥有待分发数据的节点到所述待推送节点的传输速率在所述拥有待分发数据的节点到所有待推送节点的传输速率中为最高且不为0;所述待推送节点在接收到所述数据后,作为拥有待分发数据的节点运行所述推送程序。本发明减少了数据在网络中分发的时延,有效提高了网络带宽的利用率。

    基于分级复用的日志数据流的查询共享方法和系统

    公开(公告)号:CN107193898A

    公开(公告)日:2017-09-22

    申请号:CN201710320562.8

    申请日:2017-05-09

    Inventor: 张进东 孙毓忠

    Abstract: 本发明涉及一种基于分级复用的日志数据流的查询共享方法和系统,包括:将包含多个查询语句的查询操作注册到系统,通过设定滑动窗口对日志数据流中的元组进行截取;对多个该查询语句进行预处理,提取其中具有相同子查询的查询语句,并将其所查询结果作为中间结果加以存储,该中间结果用以在多个查询操作间进行共享;从所截取元组中提取具有相同中间存储结构的元组,并将其采用共享队列的方式加以存储以在多个查询操作间进行共享。本发明针对日志流查询存储共享,保证对日志流元组的数据进行有效存储、快速索引的前提下,也为数据共享情况下的迁移提供了灵活性;针对子查询共享,通过对相同谓词查询的抽取和共享,达到计算资源共享的目的。

Patent Agency Ranking