Integration with AggregateSource