+In this dataflow, line 1 defines the *source*, in this case a `string_test_source` that generates a stream with 2 process instances (one with activities `A`, `B`, `C`, and `D` and the other with `A`, `C`, `B`, and `D`). Then, on this stream, a pipeline of two operators is applied: first (`simple_dfg_miner`) transforms the stream of events into a stream of DFG models (i.e., it mines the stream); and the other (`dfg_str_to_graphviz`) converts the DFG into a Graphviz string. Finally, a sink (`graphviz_sink`) is provided that will dump the DFG models into a Graphviz representation. Please note that corresponding `import` statements are omitted for simplicity.
0 commit comments