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 and Description
static class	WordCountTopology.SplitSentence
static class	WordCountTopology.WordCount

Field Summary

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

conf

Constructor Summary

Constructors

Constructor and Description
WordCountTopology()

Method Summary

Modifier and Type	Method and 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 Detail

WordCountTopology

public WordCountTopology()

Method Detail

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