Patent ID: 8176196

Claim:
A stream data processing method comprising the steps of: registering a query in a first node, subjecting data added with time stamps to operator execution in a second node set, and sorting the data having been subjected to operator execution according to the time stamps to output the data in a third node set; extracting, in the first node, a set of first value expressions indicating a group that assures an input order by data of the same group from the registered query, and calculating a set of second value expressions indicating a method for partitioning operator execution for each data in the plural second nodes; calculating a set of third value expressions indicating a method for performing output processing by partitioning data into the plural third nodes from the sets of the first and second value expressions, and determining a method for distributing data to the third node set from the set of third value expressions; and determining, on the basis of the distribution method for the third node set and the set of the first value expressions, a method for distributing data having been processed in the same second node so as to be processed in the same third node.