Fiddle with some docs
Reorganize code a bit more
s/MakeReduce()/ToStream()/
Add CreatePipeline() func
Add Eduction processor