EVENT DETECTION WITH CONCURRENT DATA UPDATES
First Claim
1. A method for detecting matching records among a flow of records into a database, said method comprising the steps of:
- establishing a condition for use in selecting a set of matching records;
applying a time stamp to each record in a flow of records as said each record enters a database;
incrementing said time stamp after applying said time stamp to said each record so that said each record has a different time stamp;
defining a sequence of time stamps from a first time stamp to a latest time stamp;
defining a set of current records from records in said flow of records wherein each record in said set of current records has a time stamp falling between said first time stamp and said latest time stamp;
applying said condition to said database to find a set of matching records wherein said set of matching records includes at least one current record from said set of current records and no records having a time stamp greater than said latest time stamp; and
outputting said matching records.
1 Assignment
0 Petitions
Accused Products
Abstract
An event detection system allows data to be inserted while event conditions are being checked. Each record is assigned a time stamp as it is inserted into a database. Each event condition check is assigned a time stamp range. The event condition check then produces only those matches that have at least one record with a time stamp in the range and no record with a time stamp after the range. After each event condition check, the range is changed so that, in subsequent checks, no part of a previous range is duplicated and no time stamps are excluded from every checked range. As a result of this process, records may be inserted while event conditions are being checked.
65 Citations
10 Claims
-
1. A method for detecting matching records among a flow of records into a database, said method comprising the steps of:
-
establishing a condition for use in selecting a set of matching records;
applying a time stamp to each record in a flow of records as said each record enters a database;
incrementing said time stamp after applying said time stamp to said each record so that said each record has a different time stamp;
defining a sequence of time stamps from a first time stamp to a latest time stamp;
defining a set of current records from records in said flow of records wherein each record in said set of current records has a time stamp falling between said first time stamp and said latest time stamp;
applying said condition to said database to find a set of matching records wherein said set of matching records includes at least one current record from said set of current records and no records having a time stamp greater than said latest time stamp; and
outputting said matching records. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A method for detecting matching records among a flow of records into a database, said method comprising the steps of:
-
establishing an event condition;
establishing a latest variable, an old variable and a new variable;
setting said new variable to a value of zero;
receiving a record from a flow of records;
augmenting said record with a time stamp;
replacing the value of said latest variable with said timestamp;
replacing the value of said old variable with the value of said new variable;
replacing the value of said new variable with the value of said latest variable;
inserting said augmented record into a database; and
finding all matches among records in said database for said event condition that have at least one record with a timestamp greater than said old time stamp and no records with time stamps greater than said new time stamp.
-
-
7. A system for detecting records that meet pre-selected conditions, said system comprising:
-
means for creating a flow of records;
a database for receiving each record in said flow of records;
time stamp manager means for issuing a time stamp to said each record entering said database and for incrementing said time stamp;
means for establishing a range of time stamps beginning with a first time stamp and ending with a latest time stamp;
means for storing a preselected condition;
condition manager means for applying a pre-selected condition to each record in said flow of records having a time stamp in said range of time stamps in order to find a current match between a record having a time stamp within said range and a record within said flow of records; and
means for outputting said current match. - View Dependent Claims (8, 9, 10)
-
Specification