Patent ID: 8423605

Claim:
A parallel distributed processing method executed by a computer system comprising: a parallel-distributed-processing control server for dividing sequence data into a plurality of chunks, and controlling parallel distributed processing to be applied to the sequence data; a plurality of extraction processing servers each for extracting data included in one of the plurality of chunks obtained through the dividing; and a plurality of aggregation processing servers for merging data extracted by the plurality of extraction processing servers, and processing the merged data, the sequence data including a plurality of pieces of data each including a plurality of data items including at least a first data item and a second data item, the plurality of data items each including a value, the parallel distributed processing method including: a first step of extracting, by each of the plurality of extraction processing servers, data from a respective one of the plurality of chunks according to a value in the second data item, to thereby group the data into a plurality of groups; a second step of merging, by each of the plurality of aggregation processing servers, the groups having the same value in the second data item based on an order of a value in the first data item of data included in the groups; a third step of processing, by the each of the plurality of aggregation processing servers, data in a respective one of the groups obtained through the merging by focusing on the order of the value in the first data item; and a step of notifying, by the parallel-distributed-processing control server, each of the plurality of aggregation processing servers of a result of judging that the sequence data is data which should be arranged in the order of the value in the first data item, such that each of the plurality of extraction processing servers applies the first step to data which is not arranged in the order of the value in the first data item and each of the plurality of aggregation processing servers carries out the processing focusing on the order of the value in the first data item, wherein each of the plurality of aggregation processing servers applies the second step and the third step to the data in the group in a case of reception of a notice indicating that the result of the judgment is true.