Fixed streaming aggregation example