Methods and systems for processing and storing streamed event data

A non-transitory computer-readable medium storing processor-executable instructions for processing streamed event data, wherein the instructions, when executed by one or more processors, are to cause the one or more processors to:

• receive event data at a current time;
• determine that the event data relates to a time prior to the beginning of a current time window;
• identify, based on the time, one or more stored aggregate event records each associated with a respective previous time window;
• create, for each of the identified one or more stored aggregate event records, a new aggregate event record containing updated aggregate event data adjusted by the event data;
• and
• store each new aggregate event record in association with its respective previous time window and a creation timestamp reflecting the current time.

A computer-implemented method of providing a client device with aggregated event data, the method comprising:

• receiving, from the client device, a query associated with a start time, an end time, and a snapshot time;
• identifying a plurality of stored aggregate event records, each having an associated time window, wherein the associated time windows of the plurality of stored aggregate event records are non-overlapping and span a window from the start time to the end time;
• for each identified stored aggregate event record for which there are multiple versions present, selecting a version of that stored aggregate event record having an associated creation timestamp not exceeding the snapshot time;
• and
• providing, to the client device, aggregated data from the identified and selected aggregate event records.

A non-transitory computer-readable medium storing processor-executable instructions for providing a client device with aggregate event data, wherein the instructions, when executed by one or more processors, are to cause the one or more processors to:

• receive, from the client device, a query associated with a start time, an end time, and a snapshot time;
• identify a plurality of stored aggregate event records, each having an associated time window, wherein the associated time windows of the plurality of stored aggregate event records are non-overlapping and span a window from the start time to the end time;
• for each identified stored aggregate event record for which there are multiple versions present, select a version of that stored aggregate event record having an associated creation timestamp not exceeding the snapshot time;
• and
• provide, to the client device, aggregated data from the identified and selected aggregate event records.