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.