org.apache.storm.topology

Class TopologyBuilder

java.lang.Object

org.apache.storm.topology.TopologyBuilder

All Implemented Interfaces:

java.io.Serializable

public class TopologyBuilder
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TopologyBuilder()

Method Summary

Modifier and Type	Method and Description
StormTopology	createTopology()
BoltDeclarer	setBolt(java.lang.String id, IBasicBolt bolt)
BoltDeclarer	setBolt(java.lang.String id, IBasicBolt bolt, java.lang.Number parallelismHint)
BoltDeclarer	setBolt(java.lang.String id, IRichBolt bolt)
BoltDeclarer	setBolt(java.lang.String id, IRichBolt bolt, java.lang.Number parallelismHint)
BoltDeclarer	setBolt(java.lang.String id, IWindowedBolt bolt)
BoltDeclarer	setBolt(java.lang.String id, IWindowedBolt bolt, java.lang.Number parallelismHint)
SpoutDeclarer	setSpout(java.lang.String id, IRichSpout spout)
SpoutDeclarer	setSpout(java.lang.String id, IRichSpout spout, java.lang.Number parallelismHint)

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyBuilder

public TopologyBuilder()

Method Detail

createTopology

public StormTopology createTopology()

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IRichBolt bolt)

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IRichBolt bolt,
                            java.lang.Number parallelismHint)

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IBasicBolt bolt)

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IBasicBolt bolt,
                            java.lang.Number parallelismHint)

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IWindowedBolt bolt)
                     throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IWindowedBolt bolt,
                            java.lang.Number parallelismHint)
                     throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException

setSpout

public SpoutDeclarer setSpout(java.lang.String id,
                              IRichSpout spout)

setSpout

public SpoutDeclarer setSpout(java.lang.String id,
                              IRichSpout spout,
                              java.lang.Number parallelismHint)