DISTRIBUTED STREAM PROCESSING SERVICES MERGING METHOD AND APPARATUS THEREOF
    3.
    发明申请
    DISTRIBUTED STREAM PROCESSING SERVICES MERGING METHOD AND APPARATUS THEREOF 审中-公开
    分布式流程处理服务合并方法及其设备

    公开(公告)号:US20160357612A1

    公开(公告)日:2016-12-08

    申请号:US15153264

    申请日:2016-05-12

    CPC classification number: G06F16/24568 G06F16/2246

    Abstract: The following description relates to a method and an apparatus for merging distributed stream processing services. A method for merging distributed stream processing services according to an example includes generating a global service tree based on one distributed stream processing service; when a new distributed stream processing service different from the one distributed stream processing service is inputted, generating an individual service tree for the new distributed stream processing service; and updating the global service tree by merging at least one node commonly existing in both the global service tree and the individual service tree. Common resources may be allocated to tasks (or instances) existing commonly in distributed stream processing services.

    Abstract translation: 以下描述涉及用于合并分布式流处理服务的方法和装置。 根据示例的用于合并分布式流处理服务的方法包括:基于一个分布式流处理服务生成全局服务树; 当输入与一个分布式流处理服务不同的新的分布式流处理服务时,为新的分布式流处理服务生成一个单独的服务树; 以及通过合并至少一个在全球服务树和单个服务树中存在的一个节点来更新全局服务树。 公共资源可以分配给分布式流处理服务中通常存在的任务(或实例)。

    APPARATUS AND METHOD FOR MANAGING STREAM PROCESSING TASKS
    4.
    发明申请
    APPARATUS AND METHOD FOR MANAGING STREAM PROCESSING TASKS 有权
    用于管理流程处理任务的设备和方法

    公开(公告)号:US20140351820A1

    公开(公告)日:2014-11-27

    申请号:US14225661

    申请日:2014-03-26

    Inventor: Myung-Cheol LEE

    CPC classification number: G06F9/5016 G06F9/4881

    Abstract: An apparatus and method for managing stream processing tasks are disclosed. The apparatus includes a task management unit and a task execution unit. The task management unit controls and manages the execution of assigned tasks. The task execution unit executes the tasks in response to a request from the task management unit, collects a memory load state and task execution frequency characteristics based on the execution of the tasks, detects low-frequency tasks based on the execution frequency characteristics if it is determined that a shortage of memory has occurred based on the memory load state, assigns rearrangement priorities to the low-frequency tasks, and rearranges the tasks based on the assigned rearrangement priorities.

    Abstract translation: 公开了一种用于管理流处理任务的装置和方法。 该装置包括任务管理单元和任务执行单元。 任务管理单元控制和管理分配任务的执行。 任务执行单元响应于来自任务管理单元的请求执行任务,基于任务的执行来收集存储器负载状态和任务执行频率特性,如果是,则根据执行频率特性来检测低频任务 确定基于存储器负载状态发生存储器短缺,将重排优先级分配给低频任务,并且基于所分配的重排优先级来重新排列任务。

Patent Agency Ranking