Aggregate.php Classes AggregateEvery group becomes one row, and the rows of a group can arrive in any batch, so the input is drained before the first row is emitted.