Flow aggregator implementation