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 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 Summary

Constructors

Constructor	Description
StatefulWindowingTopology()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StatefulWindowingTopology

public StatefulWindowingTopology()

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception