Package org.apache.storm.starter
Class MultiThreadWordCountTopology
java.lang.Object
org.apache.storm.topology.ConfigurableTopology
org.apache.storm.starter.MultiThreadWordCountTopology
Some topologies might spawn some threads within bolts to do some work and emit tuples from those threads.
 This is a simple wordcount topology example that mimics those use cases and might help us catch possible race conditions.
- 
Nested Class SummaryNested ClassesModifier and TypeClassDescriptionstatic class
- 
Field SummaryFields inherited from class org.apache.storm.topology.ConfigurableTopologyconf
- 
Constructor SummaryConstructors
- 
Method Summary
- 
Constructor Details- 
MultiThreadWordCountTopologypublic MultiThreadWordCountTopology()
 
- 
- 
Method Details- 
main
- 
run- Specified by:
- runin class- ConfigurableTopology
 
 
-