-
公开(公告)号:CN104036039B
公开(公告)日:2017-09-29
申请号:CN201410307198.8
申请日:2014-06-30
Applicant: 浪潮(北京)电子信息产业有限公司
IPC: G06F17/30
Abstract: 本发明公开了一种数据的并行处理方法,包括:一个或多个Map节点读取账户日志数据的分片数据,从分片数据中选出状态持续时间满足查询日期要求的候选数据记录,生成所选出的候选数据记录的第一输出参数和第二输出参数;第一输出参数至少包括账户ID,第二输出参数至少包括:状态开始日、状态结束日和状态值;一个或多个Reduce节点读取Map节点处理完的不同候选数据记录,根据候选数据记录的第一输出参数和第二输出参数分别生成各账户在查询日期范围内的完整历史状态记录;第一输出参数中账户ID相同的候选数据记录由同一个Reduce节点读取。本发明能提高大规模日志数据的处理效率。本发明还公开了一种数据的并行处理系统。
-
公开(公告)号:CN105718317A
公开(公告)日:2016-06-29
申请号:CN201610029299.2
申请日:2016-01-15
Applicant: 浪潮(北京)电子信息产业有限公司
CPC classification number: G06F9/5038 , G06F9/4881
Abstract: 本发明公开了一种任务调度方法及装置,其中,该方法包括:获取工作节点的请求信息,请求信息为工作节点存在空闲工作槽时发送的请求任务的信息;计算每个任务队列的资源消耗特征及剩余任务比例,任一任务队列的资源消耗特征为依据该任务队列中正在运行的任务的CPU占用率、内存占用率及带宽占用率进行计算得到的,任一任务队列的剩余任务比例为该任务队列中未运行任务与全部任务的比值;选取任务队列中其资源消耗特征及剩余任务比例的乘积不小于其他任务队列的任务队列为目标任务队列,利用空闲工作槽对目标任务队列中的未运行任务进行处理。由此,优先处理急需被处理的任务队列中的未运行任务,大大提高了任务执行效率。
-
公开(公告)号:CN103428282B
公开(公告)日:2016-05-18
申请号:CN201310339585.5
申请日:2013-08-06
Applicant: 浪潮(北京)电子信息产业有限公司
Abstract: 本发明公开了一种云计算数据中心的在线节能控制方法及装置,其中,所述方法包括:监控和采集云计算数据中心内各节点的负载能耗数据;按照预设的性能约束条件对所述负载能耗数据过滤,将过滤后的数据作为自适应神经网络模型的输入样本;根据所述输入样本采用自适应神经网络模型产生节能策略,并按照所述节能策略对各节点执行节能控制操作。本发明的方法和装置基于自适应神经网络模型对节点的负载能耗数据和节能策略进行模拟匹配,为云计算数据中心选择合适的节能策略,对输入样本(即负载能耗数据)进行过滤,排除无需进行节能规划的输入数据,减少模型输入样本空间规模,提高数据中心的在线节能控制效率。
-
公开(公告)号:CN105468845A
公开(公告)日:2016-04-06
申请号:CN201510824705.X
申请日:2015-11-24
Applicant: 浪潮(北京)电子信息产业有限公司
CPC classification number: G06F17/5013 , G06F17/2247
Abstract: 本发明公开了一种基于XML的Petri网运行方法及系统,该方法包括:获取Petri网的结构描述信息和基于XML描述的运行相关算法;利用结构描述信息和基于XML描述的运行相关算法,运行Petri网;其中,结构描述信息包括库所集信息、变迁集信息及流集信息。本发明中,Petri网的运行相关算法是预先使用XML进行描述的并且融入到Petri网的其它描述中,相较现有技术中引入用其它语言编写的算法,本发明有效提高了Petri网运行效率;同时,上述Petri网的结构描述信息中仅包含简单的基本结构信息,相较现有技术中PNML对Petri网的定义复杂且含有过多额外信息,本发明有利于提高Petri网的运行效率。
-
公开(公告)号:CN105279023A
公开(公告)日:2016-01-27
申请号:CN201510849248.X
申请日:2015-11-27
Applicant: 浪潮(北京)电子信息产业有限公司
Abstract: 本发明提供一种虚拟机迁移方法和装置,其中方法包括:获取各物理机的历史资源利用数据,确定超过预设标准阈值大于预设次数的报警数据,将该告警数据输入时间序列趋势预测法中自回归模型,得到预测数值,若该预测数值大于预设阈值,则得到具有该告警数据的告警物理机内各虚拟机被迁移概率,基于该被迁移概率选取待迁移虚拟机,对该待迁移虚拟机进行迁移。可有效地减少外部其他复杂因素的干扰,保证SLA,避免虚拟机资源使用率爆发性升高而造成不必要的虚拟机迁移操作,并在告警物理机出现过载前对其内虚拟机进行迁移,保证告警物理机持续不间断正常运转,且可有效减少虚拟机迁移成本,保证虚拟机迁移后告警物理机资源利用率,避免造成资源浪费。
-
公开(公告)号:CN105117605A
公开(公告)日:2015-12-02
申请号:CN201510570751.1
申请日:2015-09-09
Applicant: 浪潮(北京)电子信息产业有限公司
IPC: G06F19/00
Abstract: 本发明公开了一种案件预测的装置及方法,所述装置包括:确定单元,用于接收预测指令,并根据所述预测指令确定至少一个影响因素;根据所述至少一个影响因素,确定所述至少一个影响因素的影响权重;获取单元,用于获取所述至少一个影响因素的历史值;所述确定单元,还用于根据所述获取单元获取的所述至少一个影响因素的历史值,利用时间序列模型,确定出所述至少一个影响因素的预测值;预测单元,用于根据所述确定单元确定出的所述至少一个影响因素的影响权重及所述至少一个影响因素的预测值,预测出犯罪案件数量。本发明实现了提高案件数量预测的准确度的目的。
-
公开(公告)号:CN104504158A
公开(公告)日:2015-04-08
申请号:CN201510026026.8
申请日:2015-01-19
Applicant: 浪潮(北京)电子信息产业有限公司
IPC: G06F17/30
CPC classification number: G06F16/1847 , G06F16/24552
Abstract: 提出一种快速更新业务的内存缓存的方法和装置,基于读取的外部数据的缓存查找键值在内存缓存中进行查找,如果在所述内存缓存中查找到所述缓存查找键值,则根据内存缓存中存储的与所述缓存查找键值对应的原始数据和所述外部数据进行业务处理,处理完成后把结果更新至所述内存缓存中存储所述原始数据的位置,并将该位置对应的修改标记置为已修改。所述方法和装置减少了数据快速更新时数据库频繁地提交事务进行查询和更新的操作。
-
公开(公告)号:CN104036006A
公开(公告)日:2014-09-10
申请号:CN201410279863.7
申请日:2014-06-20
Applicant: 浪潮(北京)电子信息产业有限公司
IPC: G06F17/30
CPC classification number: G06F8/24
Abstract: 本发明公开了一种实现Windows下连接控制Hbase的方法及装置,包括:封装所有Thrift的应用程序编程接口(API)的访问接口的功能函数及获取Hadoop数据库(Hbase)元数据的函数;还包括:当用户访问Hbase时,建立HBase服务器(Server)与Hbase的连接;HBase Server将执行请求和执行的封装的功能函数及获取Hbase元数据的函数发往Hbase。本发明通过将连接和控制HBase的功能函数进行有效封装,使Windows下连接和控制HBase得到稳定,采用C#封装的功能函数可以进行移植,适用范围广。
-
公开(公告)号:CN104008153A
公开(公告)日:2014-08-27
申请号:CN201410217394.6
申请日:2014-05-21
Applicant: 浪潮(北京)电子信息产业有限公司
CPC classification number: G06F17/30312
Abstract: 本发明公开了一种面向大数据的数据处理方法和装置,该方法包括:获取处理环境数据及负载场景数据;选择处理环境数据及负载场景数据对应的压缩方式;根据所选择的压缩方式对数据进行处理;处理环境数据包括网络传输的性能指标和磁盘的性能指标;负载场景数据包括读操作比例和写操作比例,读操作比例与写操作比例相加为1。本发明能够指导在不同运行环境、不同负载场景下的压缩方式的选择,优化大数据处理性能。
-
公开(公告)号:CN105071966B
公开(公告)日:2018-07-17
申请号:CN201510487732.2
申请日:2015-08-10
Applicant: 浪潮(北京)电子信息产业有限公司
IPC: H04L12/24
Abstract: 本发明提供一种日志信息管理方法及日志抽取服务器,上述方法包括以下步骤:通过以下方案:日志抽取服务器从不同日志源中分别抽取对应类型的日志;所述日志抽取服务器将获取的日志存储至对应的临时文件并从所述临时文件中获取对应的增量日志并对所述增量日志进行存储;避免了日志记录重复,实现了对增量日志存储。
-
-
-
-
-
-
-
-
-