Package org.apache.storm.starter

Class WordCountTopology

java.lang.Object

org.apache.storm.topology.ConfigurableTopology

org.apache.storm.starter.WordCountTopology

public class WordCountTopology
extends ConfigurableTopology

This topology demonstrates Storm's stream groupings and multilang capabilities.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WordCountTopology.SplitSentence

Field Summary

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

conf

Constructor Summary

Constructors

Constructor	Description
WordCountTopology()

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

WordCountTopology

public WordCountTopology()

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

run

protected int run(String[] args)
           throws Exception

Specified by:

run in class ConfigurableTopology

Throws:

Exception