edu.iu.dsc.tws.examples.compatibility.storm

Class SentenceWordCountTopology

java.lang.Object

edu.iu.dsc.tws.task.impl.TaskWorker

org.apache.storm.topology.twister2.Twister2StormWorker

edu.iu.dsc.tws.examples.compatibility.storm.SentenceWordCountTopology

All Implemented Interfaces:

IWorker

public final class SentenceWordCountTopology
extends Twister2StormWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SentenceWordCountTopology.FastRandomSentenceSpout A spout that emits a random word
static class	SentenceWordCountTopology.SplitSentence
static class	SentenceWordCountTopology.WordCount

Field Summary

Fields inherited from class edu.iu.dsc.tws.task.impl.TaskWorker

computeEnvironment, config, persistentVolume, taskExecutor, volatileVolume, workerController, workerEnvironment, workerId

Constructor Summary

Constructors

Constructor and Description
SentenceWordCountTopology()

Method Summary

Modifier and Type	Method and Description
StormTopology	buildTopology()
static void	main(java.lang.String[] args)

Methods inherited from class org.apache.storm.topology.twister2.Twister2StormWorker

execute

Methods inherited from class edu.iu.dsc.tws.task.impl.TaskWorker

execute

Methods inherited from class java.lang.Object

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

Constructor Detail

SentenceWordCountTopology

public SentenceWordCountTopology()

Method Detail

buildTopology

public StormTopology buildTopology()

Specified by:

buildTopology in class Twister2StormWorker

main

public static void main(java.lang.String[] args)