Package org.apache.storm.starter
Class StatefulWindowingTopology
java.lang.Object
org.apache.storm.starter.StatefulWindowingTopology
A simple example that demonstrates the usage of 
IStatefulWindowedBolt 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. The
 IStatefulComponent.initState(State)
 is invoked with the previously saved state of the bolt after prepare, before the execute() method is invoked.
 
- 
Constructor SummaryConstructors
- 
Method Summary
- 
Constructor Details- 
StatefulWindowingTopologypublic StatefulWindowingTopology()
 
- 
- 
Method Details- 
main- Throws:
- Exception
 
 
-