org.thales.punch.libraries.storm.core.topology

Class StormTopologyBuilder

java.lang.Object

org.thales.punch.libraries.storm.core.topology.StormTopologyBuilder

All Implemented Interfaces:

ITopologyBuilder

public class StormTopologyBuilder
extends Object
implements ITopologyBuilder

Constructor Summary

Constructors

Constructor and Description
StormTopologyBuilder()

Method Summary

Modifier and Type	Method and Description
org.apache.storm.generated.StormTopology	getTopology()
IBoltDeclarer	setBolt(String boltComponentId, org.apache.storm.topology.IRichBolt bolt, int boltExecutors)
void	setSpout(String spoutComponentId, org.thales.punch.libraries.storm.api.ISpout spout, int spoutExecutors)

Methods inherited from class java.lang.Object

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

Constructor Detail

StormTopologyBuilder

public StormTopologyBuilder()

Method Detail

setSpout

public void setSpout(String spoutComponentId,
                     org.thales.punch.libraries.storm.api.ISpout spout,
                     int spoutExecutors)

Specified by:

setSpout in interface ITopologyBuilder

setBolt

public IBoltDeclarer setBolt(String boltComponentId,
                             org.apache.storm.topology.IRichBolt bolt,
                             int boltExecutors)

Specified by:

setBolt in interface ITopologyBuilder

getTopology

public org.apache.storm.generated.StormTopology getTopology()