Aggregation operations for timeseries streams (objectMode streams ordered by timestamp)