Package org.apache.storm.starter

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MultiThreadWordCountTopology.MultiThreadedSplitSentence

Field Summary

Fields inherited from class org.apache.storm.topology.ConfigurableTopology

conf

Constructor Summary

Constructors

Constructor	Description
MultiThreadWordCountTopology()

Method Summary

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

Methods inherited from class org.apache.storm.topology.ConfigurableTopology

getConf, loadConf, start, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Details

MultiThreadWordCountTopology

public MultiThreadWordCountTopology()

Method Details

main

public static void main(String[] args)

run

protected int run(String[] args)

Specified by:

run in class ConfigurableTopology