Managed stream & advanced aggregation