Patent ID: 8099452

Claim:
A system that facilitates event stream management, comprising: a processing unit; a system memory, coupled to the processing unit, storing system-executable instructions; an interface component operated by the processing unit, that receives physical clock information from a plurality of sources, the physical clock information being associated with a plurality of event streams received from the plurality of sources; and an event stream conditioning component operated by the processing unit that analyzes the physical clock information received from the plurality of sources, identifies physical clock misalignment, and correlates the physical clock information to establish a logical clock component representing a time relative to each of the plurality of sources, the event stream conditioning component including: a stream analyzer component that evaluates punctuation messages associated with the plurality of event streams to establish the logical clock component; an ordering component that: utilizes the logical clock component to introduce a bookmark for each event stream, the bookmark being equal to an occurrence in time when the last event for each event stream is received; determines an output bookmark representing a minimum bookmark of the bookmarks introduced for each event stream; and arranges the plurality of event streams received from the plurality of sources for output based at least upon the output bookmark; and a buffer component that queues events for each of the plurality of arranged event streams until the events are equal to or less than the output bookmark.