Stream grouping and partitioning part one