backtype.storm.topology

Class TopologyBuilder

java.lang.Object

backtype.storm.topology.TopologyBuilder

public class TopologyBuilder
extends java.lang.Object

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)
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)

setSpout

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

setSpout

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