Let me rephrase my question :
Storm keeps on aggregating same bucket after segregating tuples based on
grouped fields.
- I want to consume all the aggregated content every hour, and reset
aggregation count back to zero. Storm should not be updating this bucket
while consuming.
- Storm then contin
Use-Case :
Every hour 100K invoices (entities) are created which are pushed to Storm.
These invoices belong to 'n' users.
So Storm does group aggregation on users, and creates aggregated buckets
per user. Along with sum of invoices, bucket also contains invoices IDs, so
that we know what all invo
