EVENT STREAM CONDITIONING
First Claim
1. A system that facilitates event stream management, comprising:
- an interface component that receives physical clock information from a plurality of sources; and
an event stream conditioning component that establishes a logical clock component based upon the physical clock information.
2 Assignments
0 Petitions
Accused Products
Abstract
A distributed event processing system that can organize (e.g., order) input streams regardless of actual time of receipt is provided. This order may simply be arrival order or given explicitly on a specific event attribute, such as a timestamp or sequence number. Traditional standing event queries, such as a temporal correlation of events across multiple streams, often block if an input stream is slow or may produce an incorrect answer if events fail to arrive within the fixed time interval. In response to this situation, the subject innovation employs punctuation and heartbeats in connection with a robust and scalable event processing system. The innovation discloses mechanisms by which heartbeats and timestamps can be regularly generated by low-level nodes (e.g., sources) and propagated through the network, to unblock standing event pattern queries and align events from multiple distributed streams.
-
Citations
20 Claims
-
1. A system that facilitates event stream management, comprising:
-
an interface component that receives physical clock information from a plurality of sources; and an event stream conditioning component that establishes a logical clock component based upon the physical clock information. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13)
-
-
14. A computer-implemented method of conditioning event streams, comprising:
-
obtaining a plurality of event streams from a plurality of sources; and time aligning the event streams based at least in part upon a virtual clock. - View Dependent Claims (15, 16, 17)
-
-
18. A computer-executable system that facilitates organization of event streams, comprising:
-
computer-implemented means for buffering a plurality of event streams received from a plurality of disparate sources; computer-implemented means for analyzing punctuation indicators related to each of the event streams as a function of a logical clock; and computer-implemented means for passing a subset of the streams to an output based at least in part upon the punctuation indicators. - View Dependent Claims (19, 20)
-
Specification