A method for processing data in a data processing system, wherein computations represented by a first dataflow graph are executed, the method including: receiving, at a first component of the first dataflow graph from a data store or from an output port of a preceding component in the first dataflow graph, multiple input data records; determining a characteristic of the multiple input data records, wherein the characteristic comprises one or more values stored in fields of the multiple input data records; identifying, by a second component of the first dataflow graph, a second dataflow graph from multiple available dataflow graphs based on the determined characteristic, the second dataflow graph being a micrograph configured to be retrieved and loaded dynamically to perform operations identified by the fields of the multiple input data records, and the multiple available dataflow graphs being stored in a data storage system; processing the multiple input data records using the second dataflow graph, each of the multiple input data records being processed in parallel by different instances of the second dataflow graph; determining one or more performance metrics associated with the processing for each instance of the second dataflow graph; obtaining an identifier associated with each instance of the second dataflow graph; associating the one or more determined performance metrics with the identifier of that instance; and aggregating the one or more performance metrics with previously obtained performance metrics, comprising aggregating the one or more performance metrics that are associated with the identifier associated with each instance of the second dataflow graph. receiving, at a first component of the first dataflow graph from a data store or from an output port of a preceding component in the first dataflow graph, multiple input data records; determining a characteristic of the multiple input data records, wherein the characteristic comprises one or more values stored in fields of the multiple input data records; identifying, by a second component of the first dataflow graph, a second dataflow graph from multiple available dataflow graphs based on the determined characteristic, the second dataflow graph being a micrograph configured to be retrieved and loaded dynamically to perform operations identified by the fields of the multiple input data records, and the multiple available dataflow graphs being stored in a data storage system; processing the multiple input data records using the second dataflow graph, each of the multiple input data records being processed in parallel by different instances of the second dataflow graph; determining one or more performance metrics associated with the processing for each instance of the second dataflow graph; obtaining an identifier associated with each instance of the second dataflow graph; associating the one or more determined performance metrics with the identifier of that instance; and aggregating the one or more performance metrics with previously obtained performance metrics, comprising aggregating the one or more performance metrics that are associated with the identifier associated with each instance of the second dataflow graph.