Class MultiThreadWordCountTopology

java.lang.Object
org.apache.storm.topology.ConfigurableTopology
org.apache.storm.starter.MultiThreadWordCountTopology

public class MultiThreadWordCountTopology extends ConfigurableTopology
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.
  • Constructor Details

    • MultiThreadWordCountTopology

      public MultiThreadWordCountTopology()
  • Method Details