Hi
I've seen several simple aggregation examples on the web. Can't find one that
answers my question though.
I'm wondering if Zookeeper saves the states of bolts so if 1 aggregation bolt
crashes, then when it restarts the worker it will start from previous state. I
use acks (and might do batch processing as well.)
For example, let's say I have to count every minute how many words of the same
type I find and store them in a db.
My bolt would keep counters for each work and at the end of every minute dump
the counters it holds in memory to db.
eg:
input: The peanut is great. The ocean is great.
Bolt state after input is processed:
the:2
peanut:1
is:2
great:2
ocean:1
So if the bolt crashes before it commits to db the counters, does Zookeeper
save that state?
If not, then do you have suggestions/links on what the best way to do this is?
Thanks
-Adrian
