Apparatus and method for managing stream processing tasks

摘要

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.

主权项

1. An apparatus having a non-transitory computer readable recording medium (CRRM) containing programming instructions configured 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 predetermined policies for 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, wherein the task execution unit detects the low-frequency tasks in active tasks included in an active task pool based on their frequencies of execution or recent execution times included in the collected task execution frequency characteristics.