面向流式处理系统的内存对象管理方法及系统

    公开(公告)号:CN105242971B

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

    申请号:CN201510683179.X

    申请日:2015-10-20

    Abstract: 本发明提供一种面向流式处理系统的内存对象管理方法及系统,其中,面向流式处理系统的内存对象管理方法包括:检测内存中流数据对象的状态;若检测到流数据对象的状态为不活跃态,则将流数据对象从内存中移除,并将流数据对象移动到外部存储器。本发明提供的面向流式处理系统的内存对象管理方法及系统,能够避免有效因长期运行而造成大量不活跃的流数据对象长期占用内存,从而避免系统资源的浪费。

    轨迹数据处理方法
    32.
    发明授权

    公开(公告)号:CN105868553B

    公开(公告)日:2018-04-13

    申请号:CN201610184204.4

    申请日:2016-03-28

    Abstract: 获取起始轨迹点Ps及第i个轨迹点Pi的位置,以及所述起始轨迹点Ps至第i‑1个轨迹点Pi‑1之间的所有轨迹点形成的第i‑1条轨迹线段的拟合矢量Ri‑1’,i为大于等于1且小于等于N的整数,N表示所有轨迹点的数量;根据所述起始轨迹点Ps及所述第i个轨迹点Pi的位置,得到所述Pi与所述Ps形成的原始矢量Ri,并根据拟合矢量Ri‑1’及所述原始矢量Ri,计算得到拟合矢量Ri’;当i=N时,输出所述拟合矢量Ri’,得到所述起始轨迹点至所述第N个轨迹点之间的所有轨迹点形成的第N条轨迹线段对应的压缩轨迹线段。本发明实施例提供轨迹数据处理方法,提升了数据压缩效率。

    面向流式处理系统的内存对象管理方法及系统

    公开(公告)号:CN105242971A

    公开(公告)日:2016-01-13

    申请号:CN201510683179.X

    申请日:2015-10-20

    Abstract: 本发明提供一种面向流式处理系统的内存对象管理方法及系统,其中,面向流式处理系统的内存对象管理方法包括:检测内存中流数据对象的状态;若检测到流数据对象的状态为不活跃态,则将流数据对象从内存中移除,并将流数据对象移动到外部存储器。本发明提供的面向流式处理系统的内存对象管理方法及系统,能够避免有效因长期运行而造成大量不活跃的流数据对象长期占用内存,从而避免系统资源的浪费。

    基于分布式的数据流处理方法和系统

    公开(公告)号:CN103595651A

    公开(公告)日:2014-02-19

    申请号:CN201310482045.2

    申请日:2013-10-15

    Abstract: 本发明提供一种基于分布式的数据流处理方法和系统,通过工作节点根据从主节点接收的逻辑任务中用于指示进行指定操作的目标逻辑任务的接收速率,以及对目标逻辑任务执行指定操作的处理速率,确定指定操作对应的并行度,根据并行度,对目标逻辑任务进行整合获得物理任务,所述物理任务的数量为所述并行度,从而对物理任务并行执行指定操作,由于根据逻辑任务的接收速率和逻辑任务的处理速率,动态确定各个操作的并行度,从而解决了现有技术中由于不能适应数据流的时变性和外部负载变化所导致的系统资源的浪费或数据流处理延迟的技术问题。

    基于有向图的数据分发方法

    公开(公告)号:CN101179516B

    公开(公告)日:2010-06-09

    申请号:CN200610114497.5

    申请日:2006-11-10

    Abstract: 本发明公开了一种基于有向图的数据分发方法,该方法包括以下步骤:A、用有向图定义数据分发作业,将数据分发作业Job定义成有向图定义,即Job=(N,D,T,),其中N是节点的集合,每个节点表示一个参与数据交换的单位或软件系统;D是数据元素的集合;T是边的集合,每条边表示一个数据传输任务,包括数据以及数据的流向,每个传输任务T是个三元组(Src,Dest,Data),其中Src∈N,表示源节点;Dest∈N,表示目的节点,Src和Dest构成有向边 ,Data是D的子集,表示本次传输的数据;将用有向图定义的数据分发作业转换成相应的作业描述文件;B、将作业描述文件提交给传输控制服务器,执行数据分发传输作业;C、将执行结果通知用户。本发明的优点:可直观地表示数据分发。

    基于滑动窗口的SOAP消息传输方法

    公开(公告)号:CN101009535A

    公开(公告)日:2007-08-01

    申请号:CN200710063112.1

    申请日:2007-01-26

    Abstract: 本发明公开了一种基于滑动窗口的SOAP消息传输方法,它是将SOAP消息待传输的数据切片,将分割后得到的数据切片作为附件封装到SOAP消息中,再将含有数据切片附件的SOAP消息装入滑动窗口中,使用滑动窗口来控制和提升SOAP消息的传输速度。为了保证SOAP消息传输的可靠性,在SOAP消息级滑动窗口具体设计和实现时,对数据消息丢失、响应消息丢失、接收方收到重复数据消息以及接收方等待数据超时等情况进行了有效的分析和处理,并应用了一种应用层的拥塞控制机制,以保证SOAP消息传输的畅通。本发明的特点:充分利用了网络带宽,提高了SOAP消息传输效率,并保证消息传输的可靠性。

    保证数据交换可靠传输的方法

    公开(公告)号:CN1905518A

    公开(公告)日:2007-01-31

    申请号:CN200510088715.8

    申请日:2005-07-29

    Abstract: 本发明公开了一种数据交换可靠传输方法,它是为实现数据交换系统的数据可靠传输而提出的,它通过采用端到端的数据传输方法屏蔽中间节点对数据传输的影响,防止中间人攻击的发生,提高数据交换的可靠性;它通过定义完善的消息确认机制,实现消息传输的完整流程;通过采用数据分片和事务队列实现数据交换系统的流量控制,防止进行数据交换的节点由于处理能力和网络状况的差别产生的异常,提高系统的可靠性和处理效率;通过事务信息的持久化来实现系统的故障恢复,提高系统的容错能力,并为进一步实现断点续传提供了基础;对事务队列进行优先级划分,保证重要性高的应用能够得到优先处理,更好地适应电子政务数据交换的需求。

    一种基于压缩轨迹的地图匹配方法

    公开(公告)号:CN118500420A

    公开(公告)日:2024-08-16

    申请号:CN202410607247.3

    申请日:2024-05-16

    Abstract: 本公开提供一种基于压缩轨迹的地图匹配方法。包括基于组合距离阈值的轨迹压缩算法、针对压缩轨迹的地图匹配算法;首先对于GPS轨迹,使用组合距离阈值的轨迹压缩算法得到压缩轨迹,之后通过候选路段搜索方法,根据所述压缩轨迹和路网信息查询候选路段,得到候选路段集合,并根据所述候选路段集合计算观测概率;所述针对压缩轨迹的地图匹配算法通过输入路网信息和所述候选路段集合,进行转移路径搜索,并计算转移概率,通过所述转移概率和所述观测概率,得到状态转移图,进而利用Dijkstra算法计算最优转移序列,得到地图匹配结果。本发明地图匹配方法显著降低了地图匹配算法的时间开销,并能够得到与原始轨迹相当的地图匹配准确度。

    一种基于时空约束的轨迹跟踪方法

    公开(公告)号:CN114398590B

    公开(公告)日:2024-06-18

    申请号:CN202210037432.4

    申请日:2022-01-13

    Abstract: 本发明通过网络安全领域的方法,实现了一种基于时空约束的轨迹跟踪方法。包括需要进行运行轨迹的移动对象以及进行运行轨迹跟踪移动对象管理的服务器,所述服务器对当前移动对象的位置跟踪的同时进行轨迹压缩,其中对于位于圆形区域、位于条形区域、位于类矩形区域的移动对象各自采用适应类矩形区域的算法进行跟踪和压缩,得到并在服务器中存储符合要求的压缩轨迹数据。本发明提供的方法设计了一个在能够实现服务器对当前移动对象的位置跟踪的同时,得到符合要求的压缩轨迹,支持圆形、条形、以及类矩形区域的时空约束。并且具有较低的时间复杂度和空间复杂度。

    一种用于多云部署的流处理系统容错方法

    公开(公告)号:CN111343260B

    公开(公告)日:2021-05-28

    申请号:CN202010101719.X

    申请日:2020-02-19

    Abstract: 本发明提出一种用于多云部署的流处理系统容错方法,主要包括三个步骤:步骤1,将资源管理和分配架构设置为三层架构:任务管理器‑云管理器‑执行终端;步骤2,以云边界为切分依据,将跨云流处理任务切分为多个处理阶段,其中每个阶段中连接其它阶段的节点称为边界节点,其余节点称为云内节点;步骤3,进行容错判断和处理,两个处理阶段的边界节点间的故障采用缓存加确认的容错方法,云内节点的故障采用云内全局一致的分布式快照容错方法。

Patent Agency Ranking