Patent ID: 8782650

Claim:
A stream data processing apparatus that is coupled to a plurality of computers for processing a data element in stream data, which is configured from a plurality of time-sequence data elements, the stream data processing apparatus comprising: a communication interface configured to receive the stream data from a stream data source; and a controller, which is coupled to the communication interface, and which accumulates the received stream data in a storage resource, configured to create a plurality of partition data based on the stream data inside the storage resource and distribute the plurality of partition data to a plurality of computers by sending one or more partition data among the plurality of partition data to a computer selected as a destination computer from among the plurality of computers, wherein the data element comprises a time stamp and a value of the data element, wherein the time stamp denotes time at which the data element comprising this time stamp has been created, wherein the partition data is configured from a data element group, which is two or more consecutive data elements of the stream data, and END data that comprises end as the time stamp and null as the value, is data that denotes an end of the partition data, and is different from the data element, and wherein the data element group comprises an auxiliary data part, which is a first part of the data element group, and a result usage data part, which is a part subsequent to the first part, wherein the controller is configured to: (A) acquire, from the stream data, the data element group, which is formed by a number of data elements, wherein the number is determined based on a processing capability of the destination computer, (B) decide a number of the data elements of the auxiliary data part of the data element group acquired in based on a window size, which is a data range size, denoted by a query in which a processing content and the window size are defined with respect to the destination computer, (C) create the partition data that includes the data element group and the END data, (D) send result usage specification information, which is information for specifying a leading data element in the result usage data part that follows the auxiliary data part decided in (B) and comprises a time stamp of the oldest data element from among the one or more data elements that belong to the result usage data part, to the destination computer, and (E) send the partition data to the destination computer, and wherein the destination computer is configured to receive the partition data and to process the received partition data based on time stamps in the received partition data.