Adding in basic support for aggregation to the streams API.
Added support for grouping operations to streams.