1. A method comprising: at least one computing device configured to implement at least a producer node, a processing system node, and a sink node, wherein: the producer node is configured to generate record data comprising: a first record entry comprising information about a first activity; and a second record entry comprising information about a second activity; the processing system node is configured to access the record data, the processing system node being communicatively coupled to the producer node; the processing system node is configured to access mapping data comprising data about mapping the first record entry and the second record entry; the processing system node is configured to generate parsed data by transforming the record data using the mapping data, the parsed data being generated within a designated amount of time from the generation of the record data; the sink node is configured to generate format data comprising data about configuring the processing system node to format the parsed data, the sink node being communicatively coupled to the processing system node; the sink node is configured to provide the format data to the processing system node; the processing system node is configured to generate event data by applying the format data to the parsed data; the processing system node is configured to provide the event data to the sink node; and the sink node is configured to perform a computational task based on the event data.