backtype.storm.coordination
Class BatchSubtopologyBuilder

java.lang.Object
  extended by backtype.storm.coordination.BatchSubtopologyBuilder

public class BatchSubtopologyBuilder
extends java.lang.Object


Constructor Summary
BatchSubtopologyBuilder(java.lang.String masterBoltId, IBasicBolt masterBolt)
           
BatchSubtopologyBuilder(java.lang.String masterBoltId, IBasicBolt masterBolt, java.lang.Number boltParallelism)
           
 
Method Summary
 void extendTopology(TopologyBuilder builder)
           
 BoltDeclarer getMasterDeclarer()
           
 BoltDeclarer setBolt(java.lang.String id, IBasicBolt bolt)
           
 BoltDeclarer setBolt(java.lang.String id, IBasicBolt bolt, java.lang.Number parallelism)
           
 BoltDeclarer setBolt(java.lang.String id, IBatchBolt bolt)
           
 BoltDeclarer setBolt(java.lang.String id, IBatchBolt bolt, java.lang.Number parallelism)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BatchSubtopologyBuilder

public BatchSubtopologyBuilder(java.lang.String masterBoltId,
                               IBasicBolt masterBolt,
                               java.lang.Number boltParallelism)

BatchSubtopologyBuilder

public BatchSubtopologyBuilder(java.lang.String masterBoltId,
                               IBasicBolt masterBolt)
Method Detail

getMasterDeclarer

public BoltDeclarer getMasterDeclarer()

setBolt

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

setBolt

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

setBolt

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

setBolt

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

extendTopology

public void extendTopology(TopologyBuilder builder)