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 Summary
Modifier and TypeClassDescriptionstatic class
-
Field Summary
Fields inherited from class org.apache.storm.topology.ConfigurableTopology
conf
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
MultiThreadWordCountTopology
public MultiThreadWordCountTopology()
-
-
Method Details
-
main
-
run
- Specified by:
run
in classConfigurableTopology
-