Patent ID: 8276019
Filing Date: 2012-09-25
Classification: G06F

Abstract:
1. A stream data processing system including at least one computer for processing tuples which are time-stamped stream data, the stream data processing system comprising: a stream data reception section that receives a plurality of first tuples; a query execution section that performs a data process on the first tuples to generate a plurality of second tuples; a stream data transmission section that transmits the second tuples generated by the query execution section; and a recovery point management section that determines a recovery point for the stream data processing system, the recovery point being the information identifying the oldest one of the first tuples used for generating the second tuples or identifying a first tuple which is received by the stream data reception section earlier than the oldest one of the first tuples used for generating the second tuples; wherein the query execution section adds tuple recovery point attribute values to the generated second tuples, the tuple recovery point attribute values being the information identifying the oldest one of the first tuples used for generating the second tuples or identifying the first tuple which is received by the stream data reception section earlier than the oldest one of the first tuples used for generating the second tuples; and wherein the recovery point management section determines the recovery point for the stream data processing system by conducting a search on all the tuple recovery point attribute values managed by the stream data processing system to locate the oldest recovery point.