Class StatefulWordCounter

java.lang.Object
org.apache.storm.topology.base.BaseStatefulBolt<KeyValueState<String,Long>>
org.apache.storm.flux.examples.StatefulWordCounter
All Implemented Interfaces:
Serializable, IComponent, IStatefulBolt<KeyValueState<String,Long>>, IStatefulComponent<KeyValueState<String,Long>>

public class StatefulWordCounter extends BaseStatefulBolt<KeyValueState<String,Long>>
See Also: