Patent ID: 8190599

Claim:
A stream data processing system comprising: at least one first information processing apparatus comprising at least one computer configured to execute data processing based on either one or a plurality of pre-registered queries with respect to inputted stream data, and at least one second information processing apparatus comprising at least one computer configured to constitute a migration destination of any of the queries executing the data processing in the first information processing apparatus from the first information processing apparatus, and further comprising: a query status collection unit that is configured to collect information related to a definition structure of the inputted query and an execution status of the query; a migration cost computation unit that is configured to compute a query migration cost on a basis of information related to the definition structure and the execution status collected by the query status collection unit; a migration query decision unit that is configured to decide a query to be migrated to the second information processing apparatus from among the queries being executed in the first information processing apparatus based on the migration cost computed by the migration cost computation unit; a query migration execution unit that is configured to migrate the query, which has been decided to migrate by the migration query decision unit, from the first information processing apparatus to the second information processing apparatus in accordance with a pre-set query migration method; a resource information collection unit that is configured to collect resource information related to the first information processing apparatus in which the query is registered; and the resource information comprising at least one of a CPU utilization rate of the first information processing apparatus for each of the queries and a main memory utilization rate of the first information processing apparatus for each of the queries.