Stream data processing on multiple application timelines

A method for performing query processing on streaming data, the method comprising:

• receiving a data stream of a plurality of data items for each of a plurality of keys;
• producing a processable data stream that includes all of the received plurality of items, wherein producing the processable data stream comprises:
• for each of the data items from the data stream for each of the plurality of keys, ensuring that the data items for each key of the plurality of keys are temporally in order;
• and
• for each of the data items in the processable data stream, ensuring that the data items temporally lag no more than a given tolerance in the processable data stream.

A computer program product comprising one or more computer-readable storage media that have thereon computer-executable instructions that are structured such that, when executed by one or more processors of a computing system, cause the computing system to perform steps for performing query processing on streaming data, the steps comprising:

• receiving a data stream of a plurality of data items for each of a plurality of keys;
• producing a processable data stream that includes all of the received plurality of items, wherein producing the processable data stream comprises:
• for each of the data items from the data stream for each of the plurality of keys, ensuring that the data items for each key of the plurality of keys are temporally in order;
• and
• for each of the data items in the processable data stream, ensuring that the data items temporally lag no more than a given tolerance in the processable data stream. processable data stream.