TIME-BASED EVENT PROCESSING USING PUNCTUATION EVENTS
First Claim
1. A method, comprising:
- at a computer system, receiving a first event object comprising a first validity start time and a first validity end time, wherein the first validity end time is initially undefined or unfinalized;
after receiving the first event object, receiving a punctuation event object comprising a punctuation timestamp indicating a time subsequent to the first validity start time, wherein the punctuation event object indicates that event objects received at the computer system after the punctuation event object will have validity start times later than the time indicated by the punctuation timestamp; and
setting the first validity end time to a value later than or equal to the time indicated by the punctuation timestamp.
2 Assignments
0 Petitions
Accused Products
Abstract
Methods, systems, and computer-readable media are disclosed for time-based event processing using punctuation events. A particular method includes receiving a first event object comprising a first validity start time and a first validity end time, where the first validity end time is initially undefined. A punctuation object is received after the first event object. The punctuation event object has a punctuation timestamp indicating a time subsequent to the first validity start time. The punctuation event object indicates that event objects to be received at the computer system after the punctuation event object have validity start times later than the time indicated by the punctuation timestamp. The method includes setting the first validity end time to a value later than or equal to the time indicated by the punctuation timestamp.
100 Citations
20 Claims
-
1. A method, comprising:
-
at a computer system, receiving a first event object comprising a first validity start time and a first validity end time, wherein the first validity end time is initially undefined or unfinalized; after receiving the first event object, receiving a punctuation event object comprising a punctuation timestamp indicating a time subsequent to the first validity start time, wherein the punctuation event object indicates that event objects received at the computer system after the punctuation event object will have validity start times later than the time indicated by the punctuation timestamp; and setting the first validity end time to a value later than or equal to the time indicated by the punctuation timestamp. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A system, comprising:
-
a processor; and a memory, communicatively coupled to the processor, storing instructions that, when executed by the processor, trigger; an insertion event indicating the arrival of an unfinalized event object with a valid payload; a punctuation event represented by a punctuation event object, wherein the punctuation event object has a timestamp preventing later received event objects from overwriting the valid payload of the unfinalized event object; a lifetime shrink event creating a finalized object by setting a newly defined validity end time for the unfinalized event object. - View Dependent Claims (13, 14, 15, 16, 17)
-
-
18. A computer-readable storage medium comprising instructions, that when executed by a computer, cause the computer to:
-
receive a plurality of unfinalized event objects, wherein each unfinalized event object comprises a validity start time and a validity end time that is initially undefined or unfinalized; generate a plurality of preliminary results with respect to the plurality of unfinalized event objects; receive a punctuation event object comprising a punctuation timestamp indicating a time subsequent to the validity start times of each of the plurality of unfinalized event objects; receive a post-punctuation event object comprising a post-punctuation validity start time subsequent to the time indicated by the punctuation timestamp; convert the plurality of unfinalized event objects to a plurality of finalized event objects by setting the validity end times of each of the plurality of unfinalized event objects to be equal to the post-punctuation validity start time; and generate a plurality of finalized results with respect to the plurality of finalized event objects. - View Dependent Claims (19, 20)
-
Specification