def get_aggregator(self):
        aggregator = self.aggregator_class(
            self.aggregated_activity_class, self.activity_class)
        return aggregator
Returns the class used for aggregation
dataset/ETHPy150Open tschellenbach/Stream-Framework/stream_framework/feeds/aggregated_feed/base.py/AggregatedFeed.get_aggregator