Package org.apache.storm.starter

Class AnchoredWordCount

java.lang.Object

org.apache.storm.topology.ConfigurableTopology

org.apache.storm.starter.AnchoredWordCount

public class AnchoredWordCount
extends ConfigurableTopology

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AnchoredWordCount.RandomSentenceSpout
static class	AnchoredWordCount.SplitSentence
static class	AnchoredWordCount.WordCount

Field Summary

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

conf

Constructor Summary

Constructors

Constructor	Description
AnchoredWordCount()

Method Summary

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

AnchoredWordCount

public AnchoredWordCount()

Method Details

run

protected int run(String[] args)
           throws Exception

Specified by:

run in class ConfigurableTopology

Throws:

Exception