Package org.apache.storm.starter
Class StatefulWindowingTopology
- java.lang.Object
-
- org.apache.storm.starter.StatefulWindowingTopology
-
public class StatefulWindowingTopology extends Object
A simple example that demonstrates the usage ofIStatefulWindowedBolt
to save the state of the windowing operation to avoid re-computation in case of failures.The framework internally manages the window boundaries and does not invoke
IWindowedBolt.execute(TupleWindow)
for the already evaluated windows in case of restarts during failures. TheIStatefulComponent.initState(State)
is invoked with the previously saved state of the bolt after prepare, before the execute() method is invoked.
-
-
Constructor Summary
Constructors Constructor Description StatefulWindowingTopology()
-