Aggregation of csv data in apache storm streams