Building management system with nested stream generation

A method, comprising:

• storing, by one or more processing circuits, a plurality of directed acyclic graphs (DAGs) in a DAG database, the plurality of DAGs defining processing workflows;
• receiving, by the one or more processing circuits, a time correlated data stream from a data source;
• identifying, by the one or more processing circuits, a DAG of the DAG database that uses the time correlated data stream as an input to derive a data rollup comprising a plurality of aggregated values formed from aggregating values of the time correlated data stream in predefined intervals, identifying the DAG including determining that the DAG of the plurality of DAGs stored in the DAG database uses the time correlated data stream as an input, wherein the DAG defines one or more processing operations of a processing workflow to be applied to the time correlated data stream;
• determining a frequency at which the data rollup is queried to be displayed on a user device;
• determining that the frequency is greater than a threshold;
• responsive to determining that the frequency is greater than the threshold, generating, by the one or more processing circuits, the data rollup based on the DAG and the time correlated data stream without waiting to receive a query to display graphic data on the user device including the data rollup;
• and
• generating, by the one or more processing circuits, the graphic data to display the data rollup on the user device without aggregating the time correlated data stream in response to receiving the query to display the graphic data on the user device.

One or more non-transitory storage media storing instructions thereon, that, when executed by one or more processors, cause the one or more processors to perform operations, comprising:

• storing a plurality of directed acyclic graphs (DAGs) in a DAG database, the plurality of DAGs defining processing workflows;
• receiving a time correlated data stream from a data source;
• identifying a DAG of the DAG database that uses the time correlated data stream as an input to derive a data rollup comprising a plurality of aggregated values formed from aggregating values of the time correlated data stream in predefined intervals, identifying the DAG including determining that the DAG of the plurality of DAGs stored in the DAG database uses the time correlated data stream as an input, wherein the DAG defines one or more processing operations of a processing workflow to be applied to the time correlated data stream;
• determining a frequency at which the data rollup is queried to be displayed on a user device;
• determining that the frequency is greater than a threshold;
• responsive to determining that the frequency is greater than the threshold, generating, the data rollup based on the DAG and the time correlated data stream without waiting to receive a query to display graphic data on the user device including the data rollup;
• and
• generating the graphic data to display the data rollup on the user device without aggregating the time correlated data stream in response to receiving the query to display the graphic data on the user device.