data flow for aggregator