An exemplary method for distributed processing of streaming data on an event protocol comprises receiving a plurality of related events from the streaming data at a node, amending a state of the related events, determining an error margin based on the amended state, and updating a current data transformation based on the amended state and error margin, thereby enabling real time analysis of streaming data.