System and method for a real time data stream analyzer and alert system
First Claim
1. A computerized method for analyzing a data stream of transaction records, comprising steps of:
- (a) prestoring criteria for significance specific for different users in interest tables unique to the different users;
(b) applying finite time slices to the data stream to create successive finite feed records consisting of those transaction records occurring in the time slices;
(c) comparing the records in each finite feed record with the criteria for significance, and preparing therefrom significant records of just those transaction records matching the criteria for significance;
(d) updating an alert table from the significant records according to items of interest in the interest tables unique to the different users; and
(e) issuing alerts to the different users according to the alert table; and
wherein each successive time slice is determined as a function of the quantity of data received during application of a previous time slice.
7 Assignments
0 Petitions
Accused Products
Abstract
A computerized analyzer for a transactional data stream prepares feed records from the data stream, the feed records comprising all transaction records received in a finite time slice. A new feed record is prepared for each passing time slice, and, in a preferred embodiment, new time slices are generated during operation based on record volume received during a previous time slice. The feed records are condensed to significant feed records by selecting only those transaction records in each feed record that are significant according to prestored criteria including subscriber interest records. Once a significant feed record is prepared, it is compared with subscriber interest records to produce an alert table. An alert transmitter transmits alerts to subscribers following the alert table. Alerts are deleted from the alert table as they are sent to subscribers. The system is suited to many types of transactional data streams, and suited for such as stock quote data streams.
149 Citations
5 Claims
-
1. A computerized method for analyzing a data stream of transaction records, comprising steps of:
-
(a) prestoring criteria for significance specific for different users in interest tables unique to the different users; (b) applying finite time slices to the data stream to create successive finite feed records consisting of those transaction records occurring in the time slices; (c) comparing the records in each finite feed record with the criteria for significance, and preparing therefrom significant records of just those transaction records matching the criteria for significance; (d) updating an alert table from the significant records according to items of interest in the interest tables unique to the different users; and (e) issuing alerts to the different users according to the alert table; and wherein each successive time slice is determined as a function of the quantity of data received during application of a previous time slice. - View Dependent Claims (2, 3)
-
-
4. A computerized system for analyzing a data stream and alerting subscribers, comprising:
-
a receiver adapted for preparing successive feed records, each feed record comprising all transaction records in a data stream received in a finite time slice; a selection processor adapted for selecting those transaction records in each feed record matching prestored significance criteria, and preparing therefrom a significant feed record from each feed record; an alert generator adapted for creating an alert table of alerts to be transmitted, the alerts created by comparing transaction records in the significant feed record with prestored subscriber interest tables; and an alert transmitter for transmitting alerts to subscribers following alerts stored in the alert table, and for deleting alerts sent to subscribers from the alert table; and wherein the computerized system further comprising a time slice generator adapted for determining a new time slice based on quantity of records collected during a prior time slice. - View Dependent Claims (5)
-
Specification