This library provides a group-aggregate operator for sorted data. It assumes the input has already been sorted by group-keys and simply emits the aggregation result for the continuous same group key.
See Internals of Group-Aggregate (Using Sorted Rows).