Developing Apache Storm Applications
Also available as:
PDF

Sample Topology with Saved State

A sample topology in storm-starter, StatefulWindowingTopology, demonstrates the use of IStatefulWindowedBolt to save the state of a windowing operation and avoid recomputation in case of failures. The framework manages window boundaries internally; it does not invoke execute(TupleWindow inputWindow) for already-evaluated windows if there is a restart after a failure.