Apparatus and method for managing stream processing tasks
AssigneeElectronics and Telecommunications Research Institute
InventorMyung-Cheol LEE
Life of this patent
Estimating the term…
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.
Claims20
An apparatus for managing stream processing tasks, comprising:
- a task management unit configured to control and manage execution of assigned tasks;
- and
- a task execution unit configured to execute the tasks in response to a request from the task management unit, to collect a memory load state and task execution frequency characteristics based on the execution of the tasks, to detect 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, to assign rearrangement priorities to the low-frequency tasks, and to rearrange the tasks based on the assigned rearrangement priorities.
A method of managing stream processing tasks, comprising:
- collecting, by an apparatus for managing stream processing tasks, a memory load state and task execution frequency characteristics based on execution of tasks;
- determining, by the apparatus for managing stream processing tasks, whether or not a shortage of memory has occurred based on the collected memory load state;
- detecting, by the apparatus for managing stream processing tasks, low-frequency tasks based on the collected task execution frequency characteristics if, as a result of the determination, it is determined that a shortage of memory has occurred;
- assigning, by the apparatus for managing stream processing tasks, rearrangement priorities to the detected low-frequency tasks;
- generating, by the apparatus for managing stream processing tasks, task rearrangement information based on the assigned rearrangement priorities;
- and
- rearranging, by the apparatus for managing stream processing tasks, the tasks based on the generated task rearrangement information.
Dependencies are inferred from the claim text.