Patent ID: 8140917
Filing Date: 2012-03-20
Classification: G06F

Abstract:
1. A stream recovery method for a stream processing system using a stream distribution apparatus for distributing stream data, a stream processing apparatus for performing a query process of said distributed stream data, and a failure recovery apparatus for performing control for reentering said stream data to be lost by failure occurrence at said stream processing apparatus into said stream processing apparatus, wherein: said stream data is structured including data tuples as a query process target and a recovery point tuple for indicating a position of said data tuples in said stream data; said stream processing apparatus performs the query process for said data tuples, excludes said recovery point tuple from the query process and temporarily pools said recovery point tuple in a buffer, when in said stream processing apparatus at least one of said data tuples is instructed to be deleted, reads said recovery point tuple positioned before said data tuples as a deletion instruction target, and writes position information in said stream data indicated by said recovery point tuple in storage means; and said failure recovery apparatus reads position information in said stream data from said storage means upon detection of a failure that occurred in said stream processing apparatus, uses position information positioned lastly among said read position information, as a reenter position in said stream data, and instructs said stream distribution apparatus to reenter said stream data starting from said reenter position into said stream processing apparatus.