Patent ID: 8321865

Claim:
A computer program product for processing streaming data, the computer program product comprising: a computer readable storage medium for execution by a processing circuit for performing a method comprising: receiving a new event as part of a stream of events, the new event comprising one or more attributes, wherein an attribute of the one or more attributes of the new event comprises a key uniquely identifying an entity to which the new event corresponds; determining whether the key of the new event of the stream of events matches a key of a previous event received as part of the stream of events, said previous event being currently stored in a stored event data structure as an event to be output; in response to determining that the key of the new event matches the key of the previous event, replacing the previous event stored as the event to be output with the new event as the event to be output, wherein the replacing comprises: locating, in the stored event data structure, the previous event stored as the event to be output, the stored event data structure maintaining, for each unique entity of one or more unique entities, a latest received event associated with the unique entity, wherein the previous event stored as the event to be output is the latest event associated with the unique entity identified by the key of the new event; and updating at least one attribute of the one or more attributes of the stored event to be output to match at least one attribute of the one or more attributes of the new event; and in response to meeting a specified output condition provided for outputting the event to be output, outputting the event to be output, wherein based on replacing the previous event with the new event as the event to be output, the output event is the new event, wherein the previous event is not output.