Patent ID: 8412733
Filing Date: 2013-04-02
Classification: G06F,H04L,Y10S

Abstract:
1. A computer-implemented method of retransmitting data when processing streams of data records using a plurality of relational data stream processing programs executing on at least one data processing device and communicating with one another through data communication interfaces to form a network of a plurality of relational data stream processing programs, said method comprising: providing said plurality of relational data stream processing programs executing on said at least one data processing device for processing said streams of data records; processing said streams of data records within two or more of said plurality of said relational data stream processing programs according to stream processing operations including relational stream processing operations; detecting a need to retransmit at least one missing data record of said streams of data records; and recovering said at least one missing data record by retrieving said at least one missing data record from a buffer of a relational data stream processing program upstream of a location where said need to retransmit has been detected, wherein said relational data stream processing program is the relational data stream processing program that originally sent said at least one missing data record to said location where said need to retransmit has been detected said relational data stream processing program upstream of the location, and said relational data stream processing program upstream of the location resending said at least one missing data record to at least one other of said relational data stream processing programs that needs said retransmitting.