Recreating an oltp table and reapplying database transactions for real-time analytics

A system comprising:

• a data processing system that includes one or more processors and non-transitory machine readable storage medium having instructions stored thereon that when executed by the one or more processors cause the one or more processors to perform the process comprising:
• receiving, at the data processing system, a stream of events comprising change data for a table attribute, wherein each change data is associated with an operation type and a set of attributes for the table attribute, and wherein a first attribute of the set of attributes represents a first state of the change data and a second attribute of the set of attributes represents a second state of the change data;
• populating, by the data processing system, an in-memory table with the change data based on a token associated with the operation type and a mapping of the first attribute and the second attribute to a key attribute of the in-memory table;
• executing, by the data processing system, a continuous query on the change data for the key attribute of the in-memory table to generate events comprising data for a third attribute;
• and
• outputting, by the data processing system, the events having an output shape comprising the third attribute, wherein the events include the data for the third attribute.

A non-transitory machine readable storage medium having instructions stored thereon that when executed by one or more processors cause the one or more processors to perform a method comprising:

• receiving a stream of events comprising change data for a table attribute, wherein each change data is associated with an operation type and a set of attributes for the table attribute, and wherein a first attribute of the set of attributes represents a first state of the change data and a second attribute of the set of attributes represents a second state of the change data;
• populating an in-memory table with the change data based on a token associated with the operation type and a mapping of the first attribute and the second attribute to a key attribute of the in-memory table;
• executing a continuous query on the change data for the key attribute of the in-memory table to generate events comprising data for a third attribute;
• and
• outputting the events having an output shape comprising the third attribute, wherein the events include the data for the third attribute.