dataflow real time + aggregate

A great way to split up your pipeline based on the urgency of results aggregate-data-with-dataflow