ADAP: the Awesome Data Augmentation Pipeline

Piper proposes an implementation of Adap.Stream.Emitter where the distributed processing of each element is defined as a succession of matching rules

Adap.Stream.new/3 create a stream, it takes a source enumerable, an emitter module and a chunk size

Behaviour describing an ADAP distributed processing unit

Route element to a node/process started on demand: Adap.Unit.Router.cast({mod,arg}=unit_spec,elem) will: