公开(公告)号：CN106997395B

公开(公告)日：2020-07-03

申请号：CN201710240188.0

申请日：2017-04-13

Applicant: 南京大学

Inventor： 胡昊 ,  龚宇豪 ,  匡宏宇 ,  蔡昕辰 ,  吕建

IPC: G06F16/2455 ,  G06F16/2453

Abstract: 本发明公开一种移动感知复杂事件并行处理方法。包括以下步骤：步骤1，数据划分：对当前operator产生的数据进行数据映射，将这些数据传输给对应的后续operator；分割属于不同查询范围的数据；步骤2，数据合并：属于同一个划分的数据传输至同一个operator，对数据进行排序，并提交给operator处理模块；步骤3，数据处理：步骤3.1，数据处理，对合并后的数据提交至operator处理模块进行处理；若存在后续operator，将处理后产生的结果转入步骤1；步骤3.2，范围处理结束信号发送，表明operator可以开始处理下一查询范围数据。在移动感知复杂事件处理环境下，通过并行处理来增加系统对输入数据量的负载上限和事件处理的吞吐率时，可以使用本发明。

公开(公告)号：CN107018197A

公开(公告)日：2017-08-04

申请号：CN201710240549.1

申请日：2017-04-13

Applicant: 南京大学

Inventor： 胡昊 ,  龚宇豪 ,  匡宏宇 ,  蔡昕辰 ,  吕建

IPC: H04L29/08

CPC classification number: H04L67/1002

Abstract: 本发明公开一种支持负载均衡的动态伸缩移动感知复杂事件处理方法，包括以下步骤：步骤1、轮次时间收集与处理：分别收集每个operator所有副本对当前轮次的处理时间；计算出各副本处理时间的平均值和变异系数；步骤2、判断是否有operator计算能力不足而需要动态伸缩或需要负载均衡；步骤3、进行伸缩与负载均衡：当operator进行伸缩，即调整operator副本个数，使operator的计算资源匹配当前负载；当各副本进行负载均衡，即重新分配operator副本之间的负载，直至变异系数小于预设的阈值。本发明的技术方案使移动感知复杂事件处理方法能在运行时刻调整其operator副本数量并均衡副本间负载，从而节省移动感知复杂事件处理技术运行过程中的整体开销，并提升其吞吐率。

公开(公告)号：CN106997395A

公开(公告)日：2017-08-01

申请号：CN201710240188.0

申请日：2017-04-13

Applicant: 南京大学

Inventor： 胡昊 ,  龚宇豪 ,  匡宏宇 ,  蔡昕辰 ,  吕建

IPC: G06F17/30

Abstract: 本发明公开一种移动感知复杂事件并行处理方法。包括以下步骤：步骤1，数据划分：对当前operator产生的数据进行数据映射，将这些数据传输给对应的后续operator；分割属于不同查询范围的数据；步骤2，数据合并：属于同一个划分的数据传输至同一个operator，对数据进行排序，并提交给operator处理模块；步骤3，数据处理：步骤3.1，数据处理，对合并后的数据提交至operator处理模块进行处理；若存在后续operator，将处理后产生的结果转入步骤1；步骤3.2，范围处理结束信号发送，表明operator可以开始处理下一查询范围数据。在移动感知复杂事件处理环境下，通过并行处理来增加系统对输入数据量的负载上限和事件处理的吞吐率时，可以使用本发明。