In this session we’ll see how to implement a data transformation pipeline with Elixir GenStage and Flow.
We will process a infinite stream of data, performing aggregations over specific metrics.
As we dive deeper, we'll also look at how to recover and manage failures and errors.