一种元数据恢复方法及相关装置

    公开(公告)号:CN104202387A

    公开(公告)日:2014-12-10

    申请号:CN201410427894.2

    申请日:2014-08-27

    Inventor: 刘洋 张克星

    CPC classification number: H04L29/08

    Abstract: 本发明实施例公开了一种元数据恢复方法及相关装置,该方法可包括:接收对目标文件的写操作请求,其中,所述目标文件保存在多个数据节点上;从元数据节点获取所述目标文件的元数据,所述目标文件的元数据包含所述多个数据节点的信息;根据所述目标文件的元数据生成元数据恢复信息;向所述多个数据节点中的至少一个数据节点发送所述元数据恢复信息,所述元数据恢复信息用于被所述至少一个数据节点进行保存,并在所述元数据节点出现异常后被发送到所述元数据节点进行所述元数据的恢复。本发明实施例可以恢复NN异常时的元数据。

    检测媒体网关间电路状态的方法、交换中心和通信系统

    公开(公告)号:CN101014174A

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

    申请号:CN200710001123.7

    申请日:2007-01-18

    Inventor: 田文罡 张克星

    CPC classification number: H04L69/40 H04L65/103 H04L65/1043 H04L65/80

    Abstract: 本发明提供了一种检测媒体网关间电路状态的方法、交换中心和通信系统,属于通信领域。为了解决现有技术中检测网关间电路状态时不能确定故障电路的问题,本发明提供了上述方法,包括以下步骤:在测试呼叫的呼叫号码中指定当前测试的电路,交换中心接收到该呼叫后,根据呼叫号码选择经过测试电路的媒体网关,如果测试呼叫成功,则测试电路状态为正常,如果测试呼叫失败,则测试电路状态为不正常。本发明提供的交换中心包括:接收模块、选择模块和电路状态判定模块。本发明提供的通信系统包括:交换中心和媒体网关。本发明能检测出媒体网关间电路的状态,而且可以在不中断业务的情况下进行,为复杂TDM组网提供了一种灵活的测试维护手段。

    一种分布式系统中处理事务的方法、相关设备及系统

    公开(公告)号:CN103502940B

    公开(公告)日:2017-12-12

    申请号:CN201180003388.5

    申请日:2011-12-21

    Inventor: 张克星 刘文宇

    CPC classification number: G06F9/466

    Abstract: 本发明实施例公开了一种分布式系统中处理事务的方法、相关设备及系统,用于执行用户自定义的事务执行函数,进行事务的处理,避免客户端在处理并发事务时产生的冲突。本发明实施例方法包括:客户端向分布式系统的服务器发送注册用户定义的函数的请求,请求服务器注册该用户定义的函数,该用户定义的函数用于处理所指向的事务,当该用户定义的函数注册成功时,调用该用户定义的函数处理所指向的事务。

    一种基于分布式系统的业务分配方法及装置

    公开(公告)号:CN104537045A

    公开(公告)日:2015-04-22

    申请号:CN201410817889.2

    申请日:2014-12-24

    CPC classification number: H04L29/08 G06F16/00 G06F9/5083 H04L67/10

    Abstract: 本发明公开了一种基于分布式系统的业务分配方法及装置,用以实现根据业务的个性化需求为业务分配处理节点。所述分布式系统包括控制节点和至少两个业务节点,所述业务分配方法为:所述控制节点接收业务请求,并获取处理所述业务请求所需满足的资源约束条件;所述控制节点根据所述至少两个业务节点中每一个业务节点的资源信息和所述资源约束条件,确定满足所述资源约束条件的业务节点;所述控制节点将所述业务请求发送给确定的所述业务节点进行处理。

    一种元数据恢复方法及相关装置

    公开(公告)号:CN104202387B

    公开(公告)日:2017-11-24

    申请号:CN201410427894.2

    申请日:2014-08-27

    Inventor: 刘洋 张克星

    CPC classification number: H04L29/08

    Abstract: 本发明实施例公开了一种元数据恢复方法及相关装置,该方法可包括:接收对目标文件的写操作请求,其中,所述目标文件保存在多个数据节点上;从元数据节点获取所述目标文件的元数据,所述目标文件的元数据包含所述多个数据节点的信息;根据所述目标文件的元数据生成元数据恢复信息;向所述多个数据节点中的至少一个数据节点发送所述元数据恢复信息,所述元数据恢复信息用于被所述至少一个数据节点进行保存,并在所述元数据节点出现异常后被发送到所述元数据节点进行所述元数据的恢复。本发明实施例可以恢复NN异常时的元数据。

    一种分布式系统中处理事务的方法、相关设备及系统

    公开(公告)号:CN103502940A

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

    申请号:CN201180003388.5

    申请日:2011-12-21

    Inventor: 张克星 刘文宇

    CPC classification number: G06F9/466

    Abstract: 本发明实施例公开了一种分布式系统中处理事务的方法、相关设备及系统,用于执行用户自定义的事务执行函数,进行事务的处理,避免客户端在处理并发事务时产生的冲突。本发明实施例方法包括:客户端向分布式系统的服务器发送注册用户定义的函数的请求,请求服务器注册该用户定义的函数,该用户定义的函数用于处理所指向的事务,当该用户定义的函数注册成功时,调用该用户定义的函数处理所指向的事务。

    流处理系统的管理方法和相关设备及系统

    公开(公告)号:CN103782270B

    公开(公告)日:2017-03-08

    申请号:CN201380001567.4

    申请日:2013-10-28

    Inventor: 王澜 智伟 张克星

    CPC classification number: G06F9/50

    Abstract: 一种流处理系统的管理方法和相关设备及系统。其中,一种流处理系统的管理方法,流处理系统包括N个计算节点,N为正整数,管理方法可包括:监测N个计算节点中的第一计算节点中部署的处理单元的运行情况;若监测到处理单元的运行情况符合设定的处理单元并发实例调整条件,调整处理单元的并发实例,运行情况包括资源使用情况和/或处理性能。本发明实施例的方案有利于提高处理单元的并发实例数与实际需处理数据流大小间匹配度,进而尽量保证流处理系统的吞吐量和流处理系统资源利用率。

    一种数据分发策略的调整方法、装置及系统

    公开(公告)号:CN103873380B

    公开(公告)日:2017-10-24

    申请号:CN201410062625.0

    申请日:2014-02-24

    Inventor: 王澜 智伟 张克星

    CPC classification number: H04L12/6418

    Abstract: 本发明公开了数据分发策略的调整方法、装置及系统,属于数据处理领域。所述方法用于处理流处理系统中的流处理业务的数据,包括:所述控制装置获取每个工作装置的资源使用报告;根据所述每个工作装置的资源使用报告及预设的策略,确定处理单元调整策略,所述处理单元调整策略包括增加后处理单元数量或者减少后处理单元数量;从所述至少一个工作装置中选择至少一个工作装置作为所述处理单元调整策略的执行者;生成包括所述处理单元调整策略的调整指示,并将所述调整指示发送给被确定的工作装置。在流处理业务进行的过程中,由控制装置根据各工作装置的资源使用报告确定需要调整后处理单元的数量,避免了后处理单元的数量不可改变缺陷。

    对流数据进行处理的方法及装置

    公开(公告)号:CN104216766B

    公开(公告)日:2017-08-29

    申请号:CN201410427013.7

    申请日:2014-08-26

    CPC classification number: G06F9/46

    Abstract: 本发明公开了一种对流数据进行处理的方法及装置,属于数据处理领域。该方法包括:当对业务产生的流数据进行第一处理操作时,接收第一流处理模型,第一流处理模型包括第一处理操作对应的流算子;根据第二流处理模型,对第一流处理模型进行修改,得到第三流处理模型,第二流处理模型为流处理平台中正在运行的对流数据进行处理流处理模型;当接收到停止指令时,停止第一流合并模型;对第一流合并模型进行修改,得到第二流合并模型;当接收到启动指令时,启动第二流合并模型,通过第二流处理模型、第三流处理模型和第二流合并模块对该流数据进行处理。本发明可以在不影响原有处理操作的结果下增加流算子,并且不会造成对流数据进行处理的延迟。

    对流数据进行处理的方法及装置

    公开(公告)号:CN104216766A

    公开(公告)日:2014-12-17

    申请号:CN201410427013.7

    申请日:2014-08-26

    CPC classification number: G06F9/46

    Abstract: 本发明公开了一种对流数据进行处理的方法及装置,属于数据处理领域。该方法包括:当对业务产生的流数据进行第一处理操作时,接收第一流处理模型,第一流处理模型包括第一处理操作对应的流算子;根据第二流处理模型,对第一流处理模型进行修改,得到第三流处理模型,第二流处理模型为流处理平台中正在运行的对流数据进行处理流处理模型;当接收到停止指令时,停止第一流合并模型;对第一流合并模型进行修改,得到第二流合并模型;当接收到启动指令时,启动第二流合并模型,通过第二流处理模型、第三流处理模型和第二流合并模块对该流数据进行处理。本发明可以在不影响原有处理操作的结果下增加流算子,并且不会造成对流数据进行处理的延迟。

Patent Agency Ranking