System and method for railroad snapshot and playback

A method comprising:

• receiving a plurality of events related to train movements in a rail system;
• creating and storing in memory a first snapshot, according to a specific domain and organized in a partitioned hierarchy of one or more topics related to the rail system or domain, that include the plurality of the events, wherein a number of events in the first snapshot are based on a number of active trains;
• receiving a request for a state of the rail system;
• pulling the first snapshot from memory and events from memory received after the first snapshot based on the request;
• and
• determining a state of the rail system using the pulled first snapshot and the pulled event, wherein the state of the rail system comprises a plurality of active events of the plurality of events as of a specific time and organized by a plurality of train symbols.

A non-transitory computer-readable medium storing instructions that, when executed, causes a processor to:

• receive a plurality of events related to train movements in a rail system,
• create and store in memory a first snapshot, according to a specific domain and organized in a partitioned hierarchy of one or more topics related to the rail system or domain, that include the plurality of the events, wherein a number of events in the first snapshot are based on a number of active trains,
• receive a request for a state of the rail system,
• pull the first snapshot stored in memory and events received and stored in memory after the first snapshot based on the playback request, and
• identify a state of the rail system using the pulled first snapshot and the pulled events, wherein the state of the rail system comprises a plurality of active events of the plurality of events as of a specific time and organized by a plurality of train symbols.