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