backtype.storm.transactional
Class TransactionalTopologyBuilder

java.lang.Object
  backtype.storm.transactional.TransactionalTopologyBuilder

public class TransactionalTopologyBuilder
extends java.lang.Object

TODO: check to see if there are two topologies active with the same transactional id essentially want to implement a file lock on top of zk (use ephemeral nodes?) or just use the topology name?

Constructor Summary

TransactionalTopologyBuilder(java.lang.String id, java.lang.String spoutId, IOpaquePartitionedTransactionalSpout spout)

TransactionalTopologyBuilder(java.lang.String id, java.lang.String spoutId, IOpaquePartitionedTransactionalSpout spout, java.lang.Integer spoutParallelism)

TransactionalTopologyBuilder(java.lang.String id, java.lang.String spoutId, IPartitionedTransactionalSpout spout)

TransactionalTopologyBuilder(java.lang.String id, java.lang.String spoutId, IPartitionedTransactionalSpout spout, java.lang.Integer spoutParallelism)

TransactionalTopologyBuilder(java.lang.String id, java.lang.String spoutId, ITransactionalSpout spout)

TransactionalTopologyBuilder(java.lang.String id, java.lang.String spoutId, ITransactionalSpout spout, java.lang.Integer spoutParallelism)

Method Summary

StormTopology	buildTopology()
TopologyBuilder	buildTopologyBuilder()
SpoutDeclarer	getSpoutDeclarer()
BoltDeclarer	setBolt(java.lang.String id, IBasicBolt bolt)
BoltDeclarer	setBolt(java.lang.String id, IBasicBolt bolt, java.lang.Integer parallelism)
BoltDeclarer	setBolt(java.lang.String id, IBatchBolt bolt)
BoltDeclarer	setBolt(java.lang.String id, IBatchBolt bolt, java.lang.Integer parallelism)
BoltDeclarer	setCommitterBolt(java.lang.String id, IBatchBolt bolt)
BoltDeclarer	setCommitterBolt(java.lang.String id, IBatchBolt bolt, java.lang.Integer parallelism)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionalTopologyBuilder

public TransactionalTopologyBuilder(java.lang.String id,
                                    java.lang.String spoutId,
                                    ITransactionalSpout spout,
                                    java.lang.Integer spoutParallelism)

TransactionalTopologyBuilder

public TransactionalTopologyBuilder(java.lang.String id,
                                    java.lang.String spoutId,
                                    ITransactionalSpout spout)

TransactionalTopologyBuilder

public TransactionalTopologyBuilder(java.lang.String id,
                                    java.lang.String spoutId,
                                    IPartitionedTransactionalSpout spout,
                                    java.lang.Integer spoutParallelism)

TransactionalTopologyBuilder

public TransactionalTopologyBuilder(java.lang.String id,
                                    java.lang.String spoutId,
                                    IPartitionedTransactionalSpout spout)

TransactionalTopologyBuilder

public TransactionalTopologyBuilder(java.lang.String id,
                                    java.lang.String spoutId,
                                    IOpaquePartitionedTransactionalSpout spout,
                                    java.lang.Integer spoutParallelism)

TransactionalTopologyBuilder

public TransactionalTopologyBuilder(java.lang.String id,
                                    java.lang.String spoutId,
                                    IOpaquePartitionedTransactionalSpout spout)

Method Detail

getSpoutDeclarer

public SpoutDeclarer getSpoutDeclarer()

setBolt

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

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IBatchBolt bolt,
                            java.lang.Integer parallelism)

setCommitterBolt

public BoltDeclarer setCommitterBolt(java.lang.String id,
                                     IBatchBolt bolt)

setCommitterBolt

public BoltDeclarer setCommitterBolt(java.lang.String id,
                                     IBatchBolt bolt,
                                     java.lang.Integer parallelism)

setBolt

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

setBolt

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

buildTopologyBuilder

public TopologyBuilder buildTopologyBuilder()

buildTopology

public StormTopology buildTopology()