FIG. 13 depicts a flowchart of an example process for an emissions generator 816 of the storage engine 116 to generate an output event stream 818 for one or more consumers. In some examples, event data 122 processed by one or more shards 804 or corresponding compute engines 102 can be passed to the emissions generator 816 in addition to, or instead of, being stored in the storage 814. For example, the emissions generator 816 can receive copies of event data 122 being output by storage processors to compute engines 102 and/or the storage 814, as well as new or processed event data 122 being output by compute engines 102 back to storage processors 810 and/or to the storage 814. The emissions generator 816 can be configured to use received event data 122 to produce and emit output event streams 818 for consumers. Each output event stream 818 can contain event data 122 that matches corresponding criteria, for example based on one or more shared attributes.
