Add end event
Add mapStream function
Add reduceStream function
Add groupByStream function
Add test/converge command